Uses of Class
org.apache.flink.streaming.runtime.tasks.StreamTask

Packages that use StreamTask

Package	Description
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.async
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.

Uses of StreamTask in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators that return StreamTask

Modifier and Type	Method	Description
StreamTask<?,?>	AbstractStreamOperator.getContainingTask()
StreamTask<?,?>	StreamOperatorParameters.getContainingTask()

Methods in org.apache.flink.streaming.api.operators with parameters of type StreamTask

Modifier and Type	Method	Description
static <OUT,OP extends StreamOperator<OUT>> org.apache.flink.api.java.tuple.Tuple2<OP,Optional<ProcessingTimeService>>	StreamOperatorFactoryUtil.createOperator(StreamOperatorFactory<OUT> operatorFactory, StreamTask<OUT,?> containingTask, StreamConfig configuration, Output<StreamRecord<OUT>> output, org.apache.flink.runtime.operators.coordination.OperatorEventDispatcher operatorEventDispatcher)	Creates a new operator using a factory and makes sure that all special factory traits are properly handled.
void	AbstractStreamOperator.setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output)
void	AbstractUdfStreamOperator.setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output)
void	SetupableStreamOperator.setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output)	Deprecated. Initializes the operator.
void	SourceOperator.setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output)

Constructors in org.apache.flink.streaming.api.operators with parameters of type StreamTask

Constructor	Description
StreamOperatorParameters(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output, java.util.function.Supplier<ProcessingTimeService> processingTimeServiceFactory, org.apache.flink.runtime.operators.coordination.OperatorEventDispatcher operatorEventDispatcher)

Uses of StreamTask in org.apache.flink.streaming.api.operators.async

Methods in org.apache.flink.streaming.api.operators.async with parameters of type StreamTask

Modifier and Type	Method	Description
void	AsyncWaitOperator.setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output)

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

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

Modifier and Type	Class	Description
class	AbstractTwoInputStreamTask<IN1,IN2,OUT>	Abstract class for executing a TwoInputStreamOperator.
class	MultipleInputStreamTask<OUT>	A StreamTask for executing a MultipleInputStreamOperator and supporting the MultipleInputStreamOperator to select input for reading.
class	OneInputStreamTask<IN,OUT>	A StreamTask for executing a OneInputStreamOperator.
class	SourceOperatorStreamTask<T>	A subclass of StreamTask for executing the SourceOperator.
class	SourceStreamTask<OUT,SRC extends SourceFunction<OUT>,OP extends StreamSource<OUT,SRC>>	Deprecated. This class is based on the SourceFunction API, which is due to be removed.
class	StreamIterationHead<OUT>	A special StreamTask that is used for executing feedback edges.
class	StreamIterationTail<IN>	A special StreamTask that is used for executing feedback edges.
class	TwoInputStreamTask<IN1,IN2,OUT>	A StreamTask for executing a TwoInputStreamOperator and supporting the TwoInputStreamOperator to select input for reading.

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

Constructor	Description
FinishedOperatorChain(StreamTask<OUT,OP> containingTask, org.apache.flink.runtime.io.network.api.writer.RecordWriterDelegate<org.apache.flink.runtime.plugable.SerializationDelegate<StreamRecord<OUT>>> recordWriterDelegate)
OperatorChain(StreamTask<OUT,OP> containingTask, org.apache.flink.runtime.io.network.api.writer.RecordWriterDelegate<org.apache.flink.runtime.plugable.SerializationDelegate<StreamRecord<OUT>>> recordWriterDelegate)
RegularOperatorChain(StreamTask<OUT,OP> containingTask, org.apache.flink.runtime.io.network.api.writer.RecordWriterDelegate<org.apache.flink.runtime.plugable.SerializationDelegate<StreamRecord<OUT>>> recordWriterDelegate)