public class LocalInputChannel extends InputChannel implements BufferAvailabilityListener
InputChannel.BufferAndAvailability
channelIndex, inputGate, numBuffersIn, numBytesIn, partitionId
Constructor and Description |
---|
LocalInputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
ResultPartitionManager partitionManager,
TaskEventPublisher taskEventPublisher,
InputChannelMetrics metrics) |
LocalInputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
ResultPartitionManager partitionManager,
TaskEventPublisher taskEventPublisher,
int initialBackoff,
int maxBackoff,
InputChannelMetrics metrics) |
Modifier and Type | Method and Description |
---|---|
void |
notifyDataAvailable()
Called whenever there might be new data available.
|
String |
toString() |
int |
unsynchronizedGetNumberOfQueuedBuffers() |
checkError, getCurrentBackoff, getPartitionId, increaseBackoff, notifyChannelNonEmpty, setError
public LocalInputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, ResultPartitionManager partitionManager, TaskEventPublisher taskEventPublisher, InputChannelMetrics metrics)
public LocalInputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, ResultPartitionManager partitionManager, TaskEventPublisher taskEventPublisher, int initialBackoff, int maxBackoff, InputChannelMetrics metrics)
public void notifyDataAvailable()
BufferAvailabilityListener
notifyDataAvailable
in interface BufferAvailabilityListener
public int unsynchronizedGetNumberOfQueuedBuffers()
unsynchronizedGetNumberOfQueuedBuffers
in class InputChannel
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.