public class RemoteInputChannel extends InputChannel
Modifier and Type | Class and Description |
---|---|
static class |
RemoteInputChannel.BufferReorderingException |
InputChannel.BufferAndAvailability
channelIndex, inputGate, numBytesIn, partitionId
Constructor and Description |
---|
RemoteInputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
ConnectionID connectionId,
ConnectionManager connectionManager,
IOMetricGroup metrics) |
RemoteInputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
ConnectionID connectionId,
ConnectionManager connectionManager,
scala.Tuple2<Integer,Integer> initialAndMaxBackoff,
IOMetricGroup metrics) |
Modifier and Type | Method and Description |
---|---|
void |
failPartitionRequest() |
BufferProvider |
getBufferProvider() |
InputChannelID |
getInputChannelId() |
int |
getNumberOfQueuedBuffers() |
void |
onBuffer(Buffer buffer,
int sequenceNumber) |
void |
onEmptyBuffer(int sequenceNumber) |
void |
onError(Throwable cause) |
void |
onFailedPartitionRequest() |
String |
toString() |
checkError, getCurrentBackoff, increaseBackoff, notifyChannelNonEmpty, setError
public RemoteInputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, ConnectionID connectionId, ConnectionManager connectionManager, IOMetricGroup metrics)
public RemoteInputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, ConnectionID connectionId, ConnectionManager connectionManager, scala.Tuple2<Integer,Integer> initialAndMaxBackoff, IOMetricGroup metrics)
public void failPartitionRequest()
public int getNumberOfQueuedBuffers()
public InputChannelID getInputChannelId()
public BufferProvider getBufferProvider() throws IOException
IOException
public void onBuffer(Buffer buffer, int sequenceNumber)
public void onEmptyBuffer(int sequenceNumber)
public void onFailedPartitionRequest()
public void onError(Throwable cause)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.