Constructor and Description |
---|
SingleThreadMultiplexSourceReaderBase(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue,
java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderSupplier,
RecordEmitter<E,T,SplitStateT> recordEmitter,
Configuration config,
SourceReaderContext context)
This constructor behaves like
SingleThreadMultiplexSourceReaderBase(Supplier,
RecordEmitter, Configuration, SourceReaderContext) , but accepts a specific FutureCompletingBlockingQueue . |
SingleThreadMultiplexSourceReaderBase(java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderSupplier,
RecordEmitter<E,T,SplitStateT> recordEmitter,
Configuration config,
SourceReaderContext context)
The primary constructor for the source reader.
|
Modifier and Type | Method and Description |
---|---|
SplitReader<E,SplitT> |
SplitFetcher.getSplitReader() |
Modifier and Type | Class and Description |
---|---|
class |
KafkaPartitionSplitReader<T>
A
SplitReader implementation that reads records from Kafka partitions. |
Constructor and Description |
---|
KafkaSourceFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<Tuple3<T,Long,Long>>> elementsQueue,
java.util.function.Supplier<SplitReader<Tuple3<T,Long,Long>,KafkaPartitionSplit>> splitReaderSupplier,
java.util.function.Consumer<Collection<String>> splitFinishedHook)
Creates a new SplitFetcherManager with a single I/O threads.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.