Modifier and Type | Field and Description |
---|---|
protected SplitFetcherManager<E,SplitT> |
SourceReaderBase.splitFetcherManager
The split fetcher manager to run split fetchers.
|
Constructor and Description |
---|
SourceReaderBase(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue,
SplitFetcherManager<E,SplitT> splitFetcherManager,
RecordEmitter<E,T,SplitStateT> recordEmitter,
Configuration config,
SourceReaderContext context) |
Modifier and Type | Class and Description |
---|---|
class |
SingleThreadFetcherManager<E,SplitT extends SourceSplit>
A Fetcher Manager with a single fetching thread (I/O thread) that handles all splits
concurrently.
|
Modifier and Type | Class and Description |
---|---|
class |
KafkaSourceFetcherManager<T>
The SplitFetcherManager for Kafka source.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.