@Internal public class PulsarUnorderedFetcherManager extends PulsarFetcherManagerBase
Consumer
inside the PulsarUnorderedPartitionSplitReader
.fetchers
Constructor and Description |
---|
PulsarUnorderedFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<org.apache.pulsar.client.api.Message<byte[]>>> elementsQueue,
java.util.function.Supplier<SplitReader<org.apache.pulsar.client.api.Message<byte[]>,PulsarPartitionSplit>> splitReaderSupplier,
Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
List<PulsarPartitionSplit> |
snapshotState() |
addSplits, closeFetcher, getOrCreateFetcher, startFetcher
checkErrors, close, createSplitFetcher, getNumAliveFetchers, maybeShutdownFinishedFetchers, pauseOrResumeSplits
public PulsarUnorderedFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<org.apache.pulsar.client.api.Message<byte[]>>> elementsQueue, java.util.function.Supplier<SplitReader<org.apache.pulsar.client.api.Message<byte[]>,PulsarPartitionSplit>> splitReaderSupplier, Configuration configuration)
public List<PulsarPartitionSplit> snapshotState()
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.