org.apache.flink.streaming.runtime.io

Class StreamInputProcessor<IN>

java.lang.Object

org.apache.flink.streaming.runtime.io.StreamInputProcessor<IN>

Type Parameters:

IN - The type of the record that can be read with this record reader.

@Internal
public class StreamInputProcessor<IN>
extends Object

Input reader for OneInputStreamTask.

This internally uses a StatusWatermarkValve to keep track of Watermark and StreamStatus events, and forwards them to event subscribers once the StatusWatermarkValve determines the Watermark from all inputs has advanced, or that a StreamStatus needs to be propagated downstream to denote a status change.

Forwarding elements, watermarks, or status status elements must be protected by synchronizing on the given lock object. This ensures that we don't call methods on a OneInputStreamOperator concurrently with the timer callback or other things.

Constructor Summary

Constructors

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)

Method Summary

Modifier and Type	Method and Description
void	cleanup()
boolean	processInput()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamInputProcessor

public 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)
                     throws IOException

Throws:

IOException

Method Detail

processInput

public boolean processInput()
                     throws Exception

Throws:

Exception

cleanup

public void cleanup()
             throws IOException

Throws:

IOException