public class LocalInputChannel extends InputChannel implements BufferAvailabilityListener
InputChannel.BufferAndAvailability
channelIndex, inputGate, numBytesIn, partitionId
Constructor and Description |
---|
LocalInputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
ResultPartitionManager partitionManager,
TaskEventDispatcher taskEventDispatcher,
int initialBackoff,
int maxBackoff,
TaskIOMetricGroup metrics) |
LocalInputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
ResultPartitionManager partitionManager,
TaskEventDispatcher taskEventDispatcher,
TaskIOMetricGroup metrics) |
Modifier and Type | Method and Description |
---|---|
void |
notifyBuffersAvailable(long numBuffers)
Called whenever a new number of buffers becomes available.
|
String |
toString() |
checkError, getCurrentBackoff, increaseBackoff, notifyChannelNonEmpty, setError
public LocalInputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, ResultPartitionManager partitionManager, TaskEventDispatcher taskEventDispatcher, TaskIOMetricGroup metrics)
public LocalInputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, ResultPartitionManager partitionManager, TaskEventDispatcher taskEventDispatcher, int initialBackoff, int maxBackoff, TaskIOMetricGroup metrics)
public void notifyBuffersAvailable(long numBuffers)
BufferAvailabilityListener
notifyBuffersAvailable
in interface BufferAvailabilityListener
numBuffers
- The number of buffers that became available.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.