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.io
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 and Description
StreamTask<?,?>	AbstractStreamOperator.getContainingTask()

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

Modifier and Type	Method and Description
void	AbstractUdfStreamOperator.setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output)
void	StreamOperator.setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output) Initializes the operator.
void	AbstractStreamOperator.setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output)

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 and Description
void	AsyncWaitOperator.setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output)

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

Methods in org.apache.flink.streaming.runtime.io with parameters of type StreamTask

Modifier and Type	Method and Description
static CheckpointBarrierHandler	InputProcessorUtil.createCheckpointBarrierHandler(StreamTask<?,?> checkpointedTask, CheckpointingMode checkpointMode, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, org.apache.flink.runtime.io.network.partition.consumer.InputGate inputGate, org.apache.flink.configuration.Configuration taskManagerConfig)

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

Constructor and Description

StreamInputProcessor(org.apache.flink.runtime.io.network.partition.consumer.InputGate[] inputGates, org.apache.flink.api.common.typeutils.TypeSerializer<IN> inputSerializer, StreamTask<?,?> checkpointedTask, CheckpointingMode checkpointMode, Object lock, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, org.apache.flink.configuration.Configuration taskManagerConfig, StreamStatusMaintainer streamStatusMaintainer, OneInputStreamOperator<IN,?> streamOperator, org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup metrics, WatermarkGauge watermarkGauge)

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

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

Modifier and Type	Class and Description
class	OneInputStreamTask<IN,OUT> A StreamTask for executing a OneInputStreamOperator.
class	SourceStreamTask<OUT,SRC extends SourceFunction<OUT>,OP extends StreamSource<OUT,SRC>> StreamTask for executing a StreamSource.
class	StoppableSourceStreamTask<OUT,SRC extends SourceFunction<OUT> & org.apache.flink.api.common.functions.StoppableFunction> Stoppable task for executing stoppable streaming sources.
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.

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

Constructor and Description
OperatorChain(StreamTask<OUT,OP> containingTask, List<StreamRecordWriter<org.apache.flink.runtime.plugable.SerializationDelegate<StreamRecord<OUT>>>> streamRecordWriters)