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) |