public abstract class IndexedInputGate extends InputGate implements CheckpointableInput
InputGate
with a specific index.InputGate.InputWithData<INPUT,DATA>
AvailabilityProvider.AvailabilityHelper
availabilityHelper, priorityAvailabilityHelper
AVAILABLE
Constructor and Description |
---|
IndexedInputGate() |
Modifier and Type | Method and Description |
---|---|
void |
blockConsumption(InputChannelInfo channelInfo) |
void |
checkpointStarted(CheckpointBarrier barrier) |
void |
checkpointStopped(long cancelledCheckpointId) |
void |
convertToPriorityEvent(int channelIndex,
int sequenceNumber) |
abstract int |
getGateIndex()
Returns the index of this input gate.
|
int |
getInputGateIndex() |
finishReadRecoveredState, getAvailableFuture, getChannel, getChannelInfos, getNext, getNumberOfInputChannels, getPriorityEventAvailableFuture, getStateConsumedFuture, isFinished, pollNext, requestPartitions, resumeConsumption, sendTaskEvent, setChannelStateWriter, setup
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getChannelInfos, getNumberOfInputChannels, resumeConsumption
and, isApproximatelyAvailable, isAvailable, or
close
public abstract int getGateIndex()
public void checkpointStarted(CheckpointBarrier barrier) throws CheckpointException
checkpointStarted
in interface CheckpointableInput
CheckpointException
public void checkpointStopped(long cancelledCheckpointId)
checkpointStopped
in interface CheckpointableInput
public int getInputGateIndex()
getInputGateIndex
in interface CheckpointableInput
public void blockConsumption(InputChannelInfo channelInfo)
blockConsumption
in interface CheckpointableInput
public void convertToPriorityEvent(int channelIndex, int sequenceNumber) throws IOException
convertToPriorityEvent
in interface CheckpointableInput
IOException
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.