@Internal public final class StreamMultipleInputProcessor extends Object implements StreamInputProcessor
MultipleInputStreamOperator
.AvailabilityProvider.AvailabilityHelper
AVAILABLE
Constructor and Description |
---|
StreamMultipleInputProcessor(CheckpointedInputGate[] checkpointedInputGates,
TypeSerializer<?>[] inputSerializers,
IOManager ioManager,
StreamStatusMaintainer streamStatusMaintainer,
MultipleInputStreamOperator<?> streamOperator,
MultipleInputSelectionHandler inputSelectionHandler,
WatermarkGauge[] inputWatermarkGauges,
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 StreamMultipleInputProcessor(CheckpointedInputGate[] checkpointedInputGates, TypeSerializer<?>[] inputSerializers, IOManager ioManager, StreamStatusMaintainer streamStatusMaintainer, MultipleInputStreamOperator<?> streamOperator, MultipleInputSelectionHandler inputSelectionHandler, WatermarkGauge[] inputWatermarkGauges, OperatorChain<?,?> operatorChain, Counter numRecordsIn)
public CompletableFuture<?> getAvailableFuture()
getAvailableFuture
in interface AvailabilityProvider
public InputStatus processInput() throws Exception
processInput
in interface StreamInputProcessor
AvailabilityProvider.getAvailableFuture()
.Exception
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public CompletableFuture<Void> prepareSnapshot(ChannelStateWriter channelStateWriter, long checkpointId) throws IOException
prepareSnapshot
in interface StreamInputProcessor
IOException
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.