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.hybrid
org.apache.flink.connector.base.source.reader
org.apache.flink.connector.datagen.source
org.apache.flink.connector.file.src
org.apache.flink.connector.file.src.impl
org.apache.flink.connector.testframe.source
org.apache.flink.connector.testutils.source.reader
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.examples.statemachine.generator
org.apache.flink.table.examples.java.connectors

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>	SourceReaderFactory.createReader(SourceReaderContext readerContext) Creates a new reader to read data from the splits 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

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

Modifier and Type	Method and Description
protected void	IteratorSourceReaderBase.start(SourceReaderContext context)

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

Constructor and Description
IteratorSourceReader(SourceReaderContext context)
IteratorSourceReaderBase(SourceReaderContext context)

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

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

Modifier and Type	Method and Description
SourceReader<T,HybridSourceSplit>	HybridSource.createReader(SourceReaderContext readerContext)

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

Constructor and Description
HybridSourceReader(SourceReaderContext readerContext)

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

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

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

Modifier and Type	Method and Description
SourceReader<OUT,NumberSequenceSource.NumberSequenceSplit>	DataGeneratorSource.createReader(SourceReaderContext readerContext)
default void	GeneratorFunction.open(SourceReaderContext readerContext) Initialization method for the function.
void	GeneratingIteratorSourceReader.start(SourceReaderContext context)

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

Constructor and Description
GeneratingIteratorSourceReader(SourceReaderContext context, GeneratorFunction<E,O> generatorFunction)

Uses of SourceReaderContext in org.apache.flink.connector.file.src

Methods in org.apache.flink.connector.file.src with parameters of type SourceReaderContext

Modifier and Type	Method and Description
SourceReader<T,SplitT>	AbstractFileSource.createReader(SourceReaderContext readerContext)

Uses of SourceReaderContext in org.apache.flink.connector.file.src.impl

Constructors in org.apache.flink.connector.file.src.impl with parameters of type SourceReaderContext

Constructor and Description
FileSourceReader(SourceReaderContext readerContext, BulkFormat<T,SplitT> readerFormat, Configuration config)

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

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

Modifier and Type	Method and Description
SourceReader<OUT,FromElementsSplit>	FromElementsSource.createReader(SourceReaderContext readerContext)

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

Constructor and Description
FromElementsSourceReader(Integer limitedNum, List<T> elements, Boundedness boundedness, SourceReaderContext context)

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

Classes in org.apache.flink.connector.testutils.source.reader that implement SourceReaderContext

Modifier and Type	Class and Description
class	TestingReaderContext A testing implementation of the SourceReaderContext.

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, boolean emitProgressiveWatermarks, StreamTask.CanEmitBatchOfRecordsChecker canEmitBatchOfRecords)

Uses of SourceReaderContext in org.apache.flink.streaming.examples.statemachine.generator

Methods in org.apache.flink.streaming.examples.statemachine.generator with parameters of type SourceReaderContext

Modifier and Type	Method and Description
void	EventsGeneratorFunction.open(SourceReaderContext readerContext)

Uses of SourceReaderContext in org.apache.flink.table.examples.java.connectors

Methods in org.apache.flink.table.examples.java.connectors with parameters of type SourceReaderContext

Modifier and Type	Method and Description
SourceReader<RowData,SocketSource.DummySplit>	SocketSource.createReader(SourceReaderContext readerContext)