Uses of Interface
org.apache.flink.streaming.runtime.streamstatus.StreamStatusMaintainer

Packages that use StreamStatusMaintainer

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

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

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

Modifier and Type	Method and Description
static <OUT> SourceFunction.SourceContext<OUT>	StreamSourceContexts.getSourceContext(TimeCharacteristic timeCharacteristic, ProcessingTimeService processingTimeService, Object checkpointLock, StreamStatusMaintainer streamStatusMaintainer, Output<StreamRecord<OUT>> output, long watermarkInterval, long idleTimeout) Depending on the TimeCharacteristic, this method will return the adequate SourceFunction.SourceContext.
void	StreamSource.run(Object lockingObject, StreamStatusMaintainer streamStatusMaintainer)
void	StreamSource.run(Object lockingObject, StreamStatusMaintainer streamStatusMaintainer, Output<StreamRecord<OUT>> collector)

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

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

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)
StreamTwoInputProcessor(Collection<org.apache.flink.runtime.io.network.partition.consumer.InputGate> inputGates1, Collection<org.apache.flink.runtime.io.network.partition.consumer.InputGate> inputGates2, org.apache.flink.api.common.typeutils.TypeSerializer<IN1> inputSerializer1, org.apache.flink.api.common.typeutils.TypeSerializer<IN2> inputSerializer2, TwoInputStreamTask<IN1,IN2,?> checkpointedTask, CheckpointingMode checkpointMode, Object lock, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, org.apache.flink.configuration.Configuration taskManagerConfig, StreamStatusMaintainer streamStatusMaintainer, TwoInputStreamOperator<IN1,IN2,?> streamOperator, org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup metrics, WatermarkGauge input1WatermarkGauge, WatermarkGauge input2WatermarkGauge)

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

Classes in org.apache.flink.streaming.runtime.tasks that implement StreamStatusMaintainer

Modifier and Type	Class and Description
class	OperatorChain<OUT,OP extends StreamOperator<OUT>> The OperatorChain contains all operators that are executed as one chain within a single StreamTask.

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

Modifier and Type	Method and Description
StreamStatusMaintainer	StreamTask.getStreamStatusMaintainer()