Modifier and Type | Method and Description |
---|---|
void |
SynchronousBufferFileReader.readInto(Buffer buffer) |
void |
BufferFileReader.readInto(Buffer buffer) |
void |
AsynchronousBufferFileReader.readInto(Buffer buffer) |
void |
AsynchronousBufferFileWriter.writeBlock(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
BufferFileReader |
IOManagerAsync.createBufferFileReader(FileIOChannel.ID channelID,
RequestDoneCallback<Buffer> callback) |
abstract BufferFileReader |
IOManager.createBufferFileReader(FileIOChannel.ID channelID,
RequestDoneCallback<Buffer> callback) |
Constructor and Description |
---|
AsynchronousBufferFileReader(FileIOChannel.ID channelID,
RequestQueue<org.apache.flink.runtime.io.disk.iomanager.ReadRequest> requestQueue,
RequestDoneCallback<Buffer> callback) |
Modifier and Type | Method and Description |
---|---|
Buffer |
SpillingAdaptiveSpanningRecordDeserializer.getCurrentBuffer() |
Buffer |
SpanningRecordSerializer.getCurrentBuffer() |
Buffer |
RecordSerializer.getCurrentBuffer() |
Buffer |
RecordDeserializer.getCurrentBuffer() |
Buffer |
AdaptiveSpanningRecordDeserializer.getCurrentBuffer() |
static Buffer |
EventSerializer.toBuffer(AbstractEvent event) |
Modifier and Type | Method and Description |
---|---|
static AbstractEvent |
EventSerializer.fromBuffer(Buffer buffer,
ClassLoader classLoader) |
void |
SpillingAdaptiveSpanningRecordDeserializer.setNextBuffer(Buffer buffer) |
RecordSerializer.SerializationResult |
SpanningRecordSerializer.setNextBuffer(Buffer buffer) |
RecordSerializer.SerializationResult |
RecordSerializer.setNextBuffer(Buffer buffer) |
void |
RecordDeserializer.setNextBuffer(Buffer buffer) |
void |
AdaptiveSpanningRecordDeserializer.setNextBuffer(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
void |
ResultPartitionWriter.writeBuffer(Buffer buffer,
int targetChannel) |
Modifier and Type | Method and Description |
---|---|
Buffer |
BufferProvider.requestBuffer()
Returns a
Buffer instance from the buffer provider, if one is available. |
Buffer |
BufferProvider.requestBufferBlocking()
Returns a
Buffer instance from the buffer provider. |
Buffer |
Buffer.retain() |
Modifier and Type | Method and Description |
---|---|
boolean |
BufferProvider.addListener(EventListener<Buffer> listener)
Adds a buffer availability listener to the buffer provider.
|
Modifier and Type | Method and Description |
---|---|
Buffer |
ResultSubpartitionView.getNextBuffer()
Returns the next
Buffer instance of this queue iterator. |
Modifier and Type | Method and Description |
---|---|
abstract boolean |
ResultSubpartition.add(Buffer buffer) |
void |
ResultPartition.add(Buffer buffer,
int subpartitionIndex)
Adds a buffer to the subpartition with the given index.
|
protected void |
ResultSubpartition.updateStatistics(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
Buffer |
InputChannel.BufferAndAvailability.buffer() |
Buffer |
BufferOrEvent.getBuffer() |
Modifier and Type | Method and Description |
---|---|
void |
RemoteInputChannel.onBuffer(Buffer buffer,
int sequenceNumber) |
Constructor and Description |
---|
BufferAndAvailability(Buffer buffer,
boolean moreAvailable) |
BufferOrEvent(Buffer buffer,
int channelIndex) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.