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 StreamTwoInputProcessor<IN1,IN2> extends Object implements StreamInputProcessor
TwoInputStreamTask
.AvailabilityProvider.AvailabilityHelper
AVAILABLE
Constructor and Description |
---|
StreamTwoInputProcessor(CheckpointedInputGate[] checkpointedInputGates,
TypeSerializer<IN1> inputSerializer1,
TypeSerializer<IN2> inputSerializer2,
IOManager ioManager,
StreamStatusMaintainer streamStatusMaintainer,
TwoInputStreamOperator<IN1,IN2,?> streamOperator,
TwoInputSelectionHandler inputSelectionHandler,
WatermarkGauge input1WatermarkGauge,
WatermarkGauge input2WatermarkGauge,
OperatorChain<?,?> operatorChain,
Counter numRecordsIn) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
CompletableFuture<?> |
getAvailableFuture() |
CompletableFuture<Void> |
prepareSnapshot(ChannelStateWriter channelStateWriter,
long checkpointId) |
InputStatus |
processInput() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isApproximatelyAvailable, isAvailable
public StreamTwoInputProcessor(CheckpointedInputGate[] checkpointedInputGates, TypeSerializer<IN1> inputSerializer1, TypeSerializer<IN2> inputSerializer2, IOManager ioManager, StreamStatusMaintainer streamStatusMaintainer, TwoInputStreamOperator<IN1,IN2,?> streamOperator, TwoInputSelectionHandler inputSelectionHandler, WatermarkGauge input1WatermarkGauge, WatermarkGauge input2WatermarkGauge, OperatorChain<?,?> operatorChain, Counter numRecordsIn)
public CompletableFuture<?> getAvailableFuture()
getAvailableFuture
in interface AvailabilityProvider
public InputStatus processInput() throws Exception
processInput
in interface StreamInputProcessor
AvailabilityProvider.getAvailableFuture()
.Exception
public CompletableFuture<Void> prepareSnapshot(ChannelStateWriter channelStateWriter, long checkpointId) throws IOException
prepareSnapshot
in interface StreamInputProcessor
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.