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()
Retrieves the current target buffer and sets its size to the actual
number of written bytes.
|
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) |
static boolean |
EventSerializer.isEvent(Buffer buffer,
Class<?> eventClass,
ClassLoader classLoader)
Identifies whether the given buffer encodes the given event.
|
void |
SpillingAdaptiveSpanningRecordDeserializer.setNextBuffer(Buffer buffer) |
RecordSerializer.SerializationResult |
SpanningRecordSerializer.setNextBuffer(Buffer buffer) |
RecordSerializer.SerializationResult |
RecordSerializer.setNextBuffer(Buffer buffer)
Sets a (next) target buffer to use and continues writing remaining data
to it until it is full.
|
void |
RecordDeserializer.setNextBuffer(Buffer buffer) |
void |
AdaptiveSpanningRecordDeserializer.setNextBuffer(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
void |
ResultPartitionWriter.writeBuffer(Buffer buffer,
int targetChannel) |
void |
ResultPartitionWriter.writeBufferToAllChannels(Buffer eventBuffer)
Writes the given buffer to all available target channels.
|
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–2018 The Apache Software Foundation. All rights reserved.