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

Packages that use TwoInputStreamTask

Package	Description
org.apache.flink.streaming.runtime.io

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

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

Constructor and Description

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)