Uses of Class
org.apache.flink.streaming.runtime.io.StreamTaskSourceInput

Packages that use StreamTaskSourceInput

Package	Description
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.

Uses of StreamTaskSourceInput in org.apache.flink.streaming.runtime.io

Subclasses of StreamTaskSourceInput in org.apache.flink.streaming.runtime.io

Modifier and Type	Class	Description
class	StreamTaskExternallyInducedSourceInput<T>	A subclass of StreamTaskSourceInput for ExternallyInducedSourceReader.

Uses of StreamTaskSourceInput in org.apache.flink.streaming.runtime.tasks

Subclasses of StreamTaskSourceInput in org.apache.flink.streaming.runtime.tasks

Modifier and Type	Class	Description
class	StreamTaskFinishedOnRestoreSourceInput<T>	A special source input implementation that immediately emit END_OF_INPUT.

Methods in org.apache.flink.streaming.runtime.tasks that return StreamTaskSourceInput

Modifier and Type	Method	Description
StreamTaskSourceInput<?>	OperatorChain.ChainedSource.getSourceTaskInput()
StreamTaskSourceInput<?>	OperatorChain.getSourceTaskInput(StreamConfig.SourceInputConfig sourceInput)

Methods in org.apache.flink.streaming.runtime.tasks that return types with arguments of type StreamTaskSourceInput

Modifier and Type	Method	Description
List<StreamTaskSourceInput<?>>	OperatorChain.getSourceTaskInputs()

Constructors in org.apache.flink.streaming.runtime.tasks with parameters of type StreamTaskSourceInput

Constructor	Description
ChainedSource(WatermarkGaugeExposingOutput<StreamRecord<?>> chainedSourceOutput, StreamTaskSourceInput<?> sourceTaskInput)