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.connector.testutils.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.connector.testutils.source.reader

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

Modifier and Type	Class and Description
class	SourceReaderTestBase.ValidatingSourceOutput A source output that validates the output.
class	TestingReaderOutput<E> A ReaderOutput for testing that collects the emitted records.

Methods in org.apache.flink.connector.testutils.source.reader that return SourceOutput

Modifier and Type	Method and Description
SourceOutput<E>	TestingReaderOutput.createOutputForSplit(String splitId)
SourceOutput<Integer>	SourceReaderTestBase.ValidatingSourceOutput.createOutputForSplit(String splitId)

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.