public class RemoteInputChannel extends InputChannel
| Modifier and Type | Class and Description |
|---|---|
static class |
RemoteInputChannel.BufferReorderingException |
channelIndex, inputGate, partitionId| 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) |
String |
toString() |
notifyAvailableBufferpublic int getNumberOfQueuedBuffers()
public InputChannelID getInputChannelId()
public BufferProvider getBufferProvider() throws IOException
IOExceptionpublic void onBuffer(Buffer buffer, int sequenceNumber)
public void onEmptyBuffer(int sequenceNumber)
public void onError(Throwable cause)
Copyright © 2014–2015 The Apache Software Foundation. All rights reserved.