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

Packages that use SourceOutput

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

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

Subinterfaces of SourceOutput in org.apache.flink.api.connector.source

Modifier and Type	Interface and Description
interface	ReaderOutput<T> The interface provided by the Flink runtime to the SourceReader to emit records, and optionally watermarks, to downstream operators for message processing.

Methods in org.apache.flink.api.connector.source that return SourceOutput

Modifier and Type	Method and Description
SourceOutput<T>	ReaderOutput.createOutputForSplit(String splitId) Creates a SourceOutput for a specific Source Split.

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

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

Modifier and Type	Method and Description
void	RecordEmitter.emitRecord(E element, SourceOutput<T> output, SplitStateT splitState) Process and emit the records to the SourceOutput.

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

Classes in org.apache.flink.streaming.api.operators.source that implement SourceOutput

Modifier and Type	Class and Description
class	SourceOutputWithWatermarks<T> Implementation of the SourceOutput.