Uses of Class
org.apache.flink.api.connector.source.ReaderInfo

Packages that use ReaderInfo

Package	Description
org.apache.flink.api.connector.source
org.apache.flink.connector.testutils.source.reader
org.apache.flink.runtime.source.coordinator

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

Methods in org.apache.flink.api.connector.source that return types with arguments of type ReaderInfo

Modifier and Type	Method and Description
Map<Integer,ReaderInfo>	SplitEnumeratorContext.registeredReaders() Get the currently registered readers.
default Map<Integer,Map<Integer,ReaderInfo>>	SplitEnumeratorContext.registeredReadersOfAttempts() Get the currently registered readers of all the subtask attempts.

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

Methods in org.apache.flink.connector.testutils.source.reader that return types with arguments of type ReaderInfo

Modifier and Type	Method and Description
Map<Integer,ReaderInfo>	TestingSplitEnumeratorContext.registeredReaders()

Uses of ReaderInfo in org.apache.flink.runtime.source.coordinator

Methods in org.apache.flink.runtime.source.coordinator that return types with arguments of type ReaderInfo

Modifier and Type	Method and Description
Map<Integer,ReaderInfo>	SourceCoordinatorContext.registeredReaders()
Map<Integer,Map<Integer,ReaderInfo>>	SourceCoordinatorContext.registeredReadersOfAttempts()