Uses of Interface
org.apache.flink.api.connector.source.SourceReaderContext

Packages that use SourceReaderContext

Package	Description
org.apache.flink.api.connector.source
org.apache.flink.api.connector.source.lib
org.apache.flink.api.connector.source.lib.util
org.apache.flink.connector.base.source.reader
org.apache.flink.streaming.api.operators

Uses of SourceReaderContext in org.apache.flink.api.connector.source

Methods in org.apache.flink.api.connector.source with parameters of type SourceReaderContext

Modifier and Type	Method and Description
SourceReader<T,SplitT>	Source.createReader(SourceReaderContext readerContext) Creates a new reader to read data from the spits it gets assigned.

Uses of SourceReaderContext in org.apache.flink.api.connector.source.lib

Methods in org.apache.flink.api.connector.source.lib with parameters of type SourceReaderContext

Modifier and Type	Method and Description
SourceReader<Long,NumberSequenceSource.NumberSequenceSplit>	NumberSequenceSource.createReader(SourceReaderContext readerContext)

Uses of SourceReaderContext in org.apache.flink.api.connector.source.lib.util

Constructors in org.apache.flink.api.connector.source.lib.util with parameters of type SourceReaderContext

Constructor and Description
IteratorSourceReader(SourceReaderContext context)

Uses of SourceReaderContext in org.apache.flink.connector.base.source.reader

Fields in org.apache.flink.connector.base.source.reader declared as SourceReaderContext

Modifier and Type	Field and Description
protected SourceReaderContext	SourceReaderBase.context The context of this source reader.

Constructors in org.apache.flink.connector.base.source.reader with parameters of type SourceReaderContext

Constructor and Description
SingleThreadMultiplexSourceReaderBase(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue, SingleThreadFetcherManager<E,SplitT> splitFetcherManager, RecordEmitter<E,T,SplitStateT> recordEmitter, Configuration config, SourceReaderContext context) This constructor behaves like SingleThreadMultiplexSourceReaderBase.SingleThreadMultiplexSourceReaderBase(Supplier, RecordEmitter, Configuration, SourceReaderContext), but accepts a specific FutureCompletingBlockingQueue and SingleThreadFetcherManager.
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.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.
SourceReaderBase(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue, SplitFetcherManager<E,SplitT> splitFetcherManager, RecordEmitter<E,T,SplitStateT> recordEmitter, Configuration config, SourceReaderContext context)

Uses of SourceReaderContext in org.apache.flink.streaming.api.operators

Constructor parameters in org.apache.flink.streaming.api.operators with type arguments of type SourceReaderContext

Constructor and Description
SourceOperator(FunctionWithException<SourceReaderContext,SourceReader<OUT,SplitT>,Exception> readerFactory, OperatorEventGateway operatorEventGateway, SimpleVersionedSerializer<SplitT> splitSerializer, WatermarkStrategy<OUT> watermarkStrategy, ProcessingTimeService timeService, Configuration configuration, String localHostname)