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,
IOMetricGroup metrics) |
LocalInputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
ResultPartitionManager partitionManager,
TaskEventDispatcher taskEventDispatcher,
scala.Tuple2<Integer,Integer> initialAndMaxBackoff,
IOMetricGroup 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, IOMetricGroup metrics)
public LocalInputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, ResultPartitionManager partitionManager, TaskEventDispatcher taskEventDispatcher, scala.Tuple2<Integer,Integer> initialAndMaxBackoff, IOMetricGroup metrics)
public void notifyBuffersAvailable(long numBuffers)
BufferAvailabilityListener
notifyBuffersAvailable
in interface BufferAvailabilityListener
numBuffers
- The number of buffers that became available.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.