Modifier and Type | Method and Description |
---|---|
void |
PulsarRecordEmitter.emitRecord(PulsarMessage<T> element,
SourceOutput<T> output,
PulsarPartitionSplitState splitState) |
Modifier and Type | Method and Description |
---|---|
protected SplitFetcher<PulsarMessage<T>,PulsarPartitionSplit> |
PulsarFetcherManagerBase.getOrCreateFetcher(String splitId) |
Modifier and Type | Method and Description |
---|---|
protected void |
PulsarFetcherManagerBase.startFetcher(SplitFetcher<PulsarMessage<T>,PulsarPartitionSplit> fetcher) |
Constructor and Description |
---|
PulsarMessageCollector(String splitId,
RecordsBySplits.Builder<PulsarMessage<T>> builder) |
Constructor and Description |
---|
PulsarOrderedSourceReader(FutureCompletingBlockingQueue<RecordsWithSplitIds<PulsarMessage<OUT>>> elementsQueue,
java.util.function.Supplier<PulsarOrderedPartitionSplitReader<OUT>> splitReaderSupplier,
Configuration configuration,
SourceReaderContext context,
SourceConfiguration sourceConfiguration,
org.apache.pulsar.client.api.PulsarClient pulsarClient,
org.apache.pulsar.client.admin.PulsarAdmin pulsarAdmin) |
PulsarUnorderedSourceReader(FutureCompletingBlockingQueue<RecordsWithSplitIds<PulsarMessage<OUT>>> elementsQueue,
java.util.function.Supplier<PulsarUnorderedPartitionSplitReader<OUT>> splitReaderSupplier,
Configuration configuration,
SourceReaderContext context,
SourceConfiguration sourceConfiguration,
org.apache.pulsar.client.api.PulsarClient pulsarClient,
org.apache.pulsar.client.admin.PulsarAdmin pulsarAdmin,
org.apache.pulsar.client.api.transaction.TransactionCoordinatorClient coordinatorClient) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.