public class LocalInputChannel extends InputChannel implements BufferAvailabilityListener
InputChannel.BufferAndAvailability
channelInfo, consumedSubpartitionIndex, initialBackoff, inputGate, maxBackoff, numBuffersIn, numBytesIn, partitionId
Constructor and Description |
---|
LocalInputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
int consumedSubpartitionIndex,
ResultPartitionManager partitionManager,
TaskEventPublisher taskEventPublisher,
int initialBackoff,
int maxBackoff,
Counter numBytesIn,
Counter numBuffersIn,
ChannelStateWriter stateWriter) |
Modifier and Type | Method and Description |
---|---|
void |
acknowledgeAllRecordsProcessed()
When received
EndOfData from one channel, it need to acknowledge after this event get
processed. |
void |
checkpointStarted(CheckpointBarrier barrier)
Called by task thread when checkpointing is started (e.g., any input channel received
barrier).
|
void |
checkpointStopped(long checkpointId)
Called by task thread on cancel/complete to clean-up temporary data.
|
void |
notifyDataAvailable()
Called whenever there might be new data available.
|
protected void |
requestSubpartition()
Requests the subpartition specified by
InputChannel.partitionId and InputChannel.consumedSubpartitionIndex . |
void |
resumeConsumption()
After sending a
CheckpointBarrier of
exactly-once mode, the upstream will be blocked and become unavailable. |
String |
toString() |
int |
unsynchronizedGetNumberOfQueuedBuffers() |
checkError, convertToPriorityEvent, getChannelIndex, getChannelInfo, getConsumedSubpartitionIndex, getCurrentBackoff, getPartitionId, increaseBackoff, notifyBufferAvailable, notifyChannelNonEmpty, notifyPriorityEvent, setError, unsynchronizedGetSizeOfQueuedBuffers
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
notifyPriorityEvent
public LocalInputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, int consumedSubpartitionIndex, ResultPartitionManager partitionManager, TaskEventPublisher taskEventPublisher, int initialBackoff, int maxBackoff, Counter numBytesIn, Counter numBuffersIn, ChannelStateWriter stateWriter)
public void checkpointStarted(CheckpointBarrier barrier) throws CheckpointException
InputChannel
checkpointStarted
in class InputChannel
CheckpointException
public void checkpointStopped(long checkpointId)
InputChannel
checkpointStopped
in class InputChannel
protected void requestSubpartition() throws IOException
InputChannel
InputChannel.partitionId
and InputChannel.consumedSubpartitionIndex
.IOException
public void notifyDataAvailable()
BufferAvailabilityListener
notifyDataAvailable
in interface BufferAvailabilityListener
public void resumeConsumption()
InputChannel
CheckpointBarrier
of
exactly-once mode, the upstream will be blocked and become unavailable. This method tries to
unblock the corresponding upstream and resume data consumption.resumeConsumption
in class InputChannel
public void acknowledgeAllRecordsProcessed() throws IOException
InputChannel
EndOfData
from one channel, it need to acknowledge after this event get
processed.acknowledgeAllRecordsProcessed
in class InputChannel
IOException
public int unsynchronizedGetNumberOfQueuedBuffers()
unsynchronizedGetNumberOfQueuedBuffers
in class InputChannel
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.