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

Packages that use ReaderOutput

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

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

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

Modifier and Type	Method and Description
InputStatus	SourceReader.pollNext(ReaderOutput<T> output) Poll the next available record into the SourceOutput.

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

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

Modifier and Type	Method and Description
InputStatus	IteratorSourceReader.pollNext(ReaderOutput<E> output)

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

Methods in org.apache.flink.connector.base.source.reader with parameters of type ReaderOutput

Modifier and Type	Method and Description
InputStatus	SourceReaderBase.pollNext(ReaderOutput<T> output)

Uses of ReaderOutput in org.apache.flink.streaming.api.operators.source

Methods in org.apache.flink.streaming.api.operators.source that return ReaderOutput

Modifier and Type	Method and Description
ReaderOutput<T>	StreamingTimestampsAndWatermarks.createMainOutput(PushingAsyncDataInput.DataOutput<T> output)
ReaderOutput<T>	TimestampsAndWatermarks.createMainOutput(PushingAsyncDataInput.DataOutput<T> output) Creates the ReaderOutput for the source reader, than internally runs the timestamp extraction and watermark generation.
ReaderOutput<T>	BatchTimestampsAndWatermarks.createMainOutput(PushingAsyncDataInput.DataOutput<T> output)