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 |
---|---|
abstract void |
announceBufferSize(int bufferSize) |
void |
blockConsumption(InputChannelInfo channelInfo) |
void |
checkpointStarted(CheckpointBarrier barrier) |
void |
checkpointStopped(long cancelledCheckpointId) |
void |
convertToPriorityEvent(int channelIndex,
int sequenceNumber) |
abstract int |
getBuffersInUseCount() |
abstract int |
getGateIndex()
Returns the index of this input gate.
|
int |
getInputGateIndex() |
abstract List<InputChannelInfo> |
getUnfinishedChannels()
Returns the list of channels that have not received EndOfPartitionEvent.
|
acknowledgeAllRecordsProcessed, finishReadRecoveredState, getAvailableFuture, getChannel, getChannelInfos, getNext, getNumberOfInputChannels, getPriorityEventAvailableFuture, getStateConsumedFuture, hasReceivedEndOfData, 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 abstract List<InputChannelInfo> getUnfinishedChannels()
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
public abstract int getBuffersInUseCount()
public abstract void announceBufferSize(int bufferSize)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.