Uses of Interface
org.apache.flink.connector.base.source.reader.RecordsWithSplitIds

Packages that use RecordsWithSplitIds

Package	Description
org.apache.flink.connector.base.source.reader
org.apache.flink.connector.base.source.reader.fetcher
org.apache.flink.connector.base.source.reader.splitreader

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

Classes in org.apache.flink.connector.base.source.reader that implement RecordsWithSplitIds

Modifier and Type	Class	Description
class	RecordsBySplits<E>	An implementation of RecordsWithSplitIds to host all the records by splits.

Uses of RecordsWithSplitIds in org.apache.flink.connector.base.source.reader.fetcher

Methods in org.apache.flink.connector.base.source.reader.fetcher that return types with arguments of type RecordsWithSplitIds

Modifier and Type	Method	Description
FutureCompletingBlockingQueue<RecordsWithSplitIds<E>>	SplitFetcherManager.getQueue()	Return the queue contains data produced by split fetchers.This method is Internal and only used in SourceReaderBase.

Uses of RecordsWithSplitIds in org.apache.flink.connector.base.source.reader.splitreader

Methods in org.apache.flink.connector.base.source.reader.splitreader that return RecordsWithSplitIds

Modifier and Type	Method	Description
RecordsWithSplitIds<E>	SplitReader.fetch()	Fetch elements into the blocking queue for the given splits.