IN1
- The type of the records that arrive on the first inputIN2
- The type of the records that arrive on the second input@Internal public final class StreamTwoInputSelectableProcessor<IN1,IN2> extends Object implements StreamInputProcessor
TwoInputSelectableStreamTask
in the case that the operator is InputSelectable.Constructor and Description |
---|
StreamTwoInputSelectableProcessor(Collection<InputGate> inputGates1,
Collection<InputGate> inputGates2,
TypeSerializer<IN1> inputSerializer1,
TypeSerializer<IN2> inputSerializer2,
StreamTask<?,?> streamTask,
CheckpointingMode checkpointingMode,
Object lock,
IOManager ioManager,
Configuration taskManagerConfig,
StreamStatusMaintainer streamStatusMaintainer,
TwoInputStreamOperator<IN1,IN2,?> streamOperator,
WatermarkGauge input1WatermarkGauge,
WatermarkGauge input2WatermarkGauge,
String taskName,
OperatorChain<?,?> operatorChain) |
public StreamTwoInputSelectableProcessor(Collection<InputGate> inputGates1, Collection<InputGate> inputGates2, TypeSerializer<IN1> inputSerializer1, TypeSerializer<IN2> inputSerializer2, StreamTask<?,?> streamTask, CheckpointingMode checkpointingMode, Object lock, IOManager ioManager, Configuration taskManagerConfig, StreamStatusMaintainer streamStatusMaintainer, TwoInputStreamOperator<IN1,IN2,?> streamOperator, WatermarkGauge input1WatermarkGauge, WatermarkGauge input2WatermarkGauge, String taskName, OperatorChain<?,?> operatorChain) throws IOException
IOException
public boolean processInput() throws Exception
processInput
in interface StreamInputProcessor
StreamTaskInput
is finished.Exception
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.