public class RemoteInputChannel extends InputChannel
InputChannel.BufferAndAvailability
channelIndex, inputGate, numBytesIn, partitionId
Constructor and Description |
---|
RemoteInputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
ConnectionID connectionId,
ConnectionManager connectionManager,
int initialBackOff,
int maxBackoff,
TaskIOMetricGroup metrics) |
RemoteInputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
ConnectionID connectionId,
ConnectionManager connectionManager,
TaskIOMetricGroup metrics) |
Modifier and Type | Method and Description |
---|---|
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, TaskIOMetricGroup metrics)
public RemoteInputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, ConnectionID connectionId, ConnectionManager connectionManager, int initialBackOff, int maxBackoff, TaskIOMetricGroup metrics)
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.