public abstract class InputChannel extends Object
ResultSubpartitionView
.
For each channel, the consumption life cycle is as follows:
Modifier and Type | Field and Description |
---|---|
protected int |
channelIndex |
protected SingleInputGate |
inputGate |
protected ResultPartitionID |
partitionId |
Modifier | Constructor and Description |
---|---|
protected |
InputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
scala.Tuple2<Integer,Integer> initialAndMaxBackoff) |
Modifier and Type | Method and Description |
---|---|
protected void |
checkError()
Checks for an error and rethrows it if one was reported.
|
protected int |
getCurrentBackoff()
Returns the current backoff in ms.
|
protected boolean |
increaseBackoff()
Increases the current backoff and returns whether the operation was successful.
|
protected void |
notifyAvailableBuffer()
Notifies the owning
SingleInputGate about an available Buffer instance. |
protected void |
setError(Throwable cause)
Atomically sets an error for this channel and notifies the input gate about available data to
trigger querying this channel by the task thread.
|
protected final int channelIndex
protected final ResultPartitionID partitionId
protected final SingleInputGate inputGate
protected InputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, scala.Tuple2<Integer,Integer> initialAndMaxBackoff)
protected void notifyAvailableBuffer()
SingleInputGate
about an available Buffer
instance.protected void checkError() throws IOException
IOException
protected void setError(Throwable cause)
protected int getCurrentBackoff()
protected boolean increaseBackoff()
true
, iff the operation was successful. Otherwise, false
.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.