Uses of Interface
org.apache.flink.runtime.io.network.buffer.Buffer

Packages that use Buffer

Package	Description
org.apache.flink.runtime.io.disk.iomanager
org.apache.flink.runtime.io.network.api.serialization
org.apache.flink.runtime.io.network.buffer
org.apache.flink.runtime.io.network.partition
org.apache.flink.runtime.io.network.partition.consumer

Uses of Buffer in org.apache.flink.runtime.io.disk.iomanager

Methods in org.apache.flink.runtime.io.disk.iomanager with parameters of type Buffer

Modifier and Type	Method and Description
boolean	BufferFileChannelReader.readBufferFromFileChannel(Buffer buffer) Reads data from the object's file channel into the given buffer.
void	AsynchronousBufferFileReader.readInto(Buffer buffer)
void	SynchronousBufferFileReader.readInto(Buffer buffer)
void	BufferFileReader.readInto(Buffer buffer)
void	AsynchronousBufferFileWriter.writeBlock(Buffer buffer) Writes the given block asynchronously.

Method parameters in org.apache.flink.runtime.io.disk.iomanager with type arguments of type Buffer

Modifier and Type	Method and Description
abstract BufferFileReader	IOManager.createBufferFileReader(FileIOChannel.ID channelID, RequestDoneCallback<Buffer> callback)
BufferFileReader	IOManagerAsync.createBufferFileReader(FileIOChannel.ID channelID, RequestDoneCallback<Buffer> callback)

Constructor parameters in org.apache.flink.runtime.io.disk.iomanager with type arguments of type Buffer

Constructor and Description
AsynchronousBufferFileReader(FileIOChannel.ID channelID, RequestQueue<org.apache.flink.runtime.io.disk.iomanager.ReadRequest> requestQueue, RequestDoneCallback<Buffer> callback)

Uses of Buffer in org.apache.flink.runtime.io.network.api.serialization

Methods in org.apache.flink.runtime.io.network.api.serialization that return Buffer

Modifier and Type	Method and Description
Buffer	RecordDeserializer.getCurrentBuffer()
Buffer	SpillingAdaptiveSpanningRecordDeserializer.getCurrentBuffer()
static Buffer	EventSerializer.toBuffer(AbstractEvent event)

Methods in org.apache.flink.runtime.io.network.api.serialization with parameters of type Buffer

Modifier and Type	Method and Description
static AbstractEvent	EventSerializer.fromBuffer(Buffer buffer, ClassLoader classLoader)
static boolean	EventSerializer.isEvent(Buffer buffer, Class<?> eventClass) Identifies whether the given buffer encodes the given event.
void	RecordDeserializer.setNextBuffer(Buffer buffer)
void	SpillingAdaptiveSpanningRecordDeserializer.setNextBuffer(Buffer buffer)

Uses of Buffer in org.apache.flink.runtime.io.network.buffer

Classes in org.apache.flink.runtime.io.network.buffer that implement Buffer

Modifier and Type	Class and Description
class	NetworkBuffer Wrapper for pooled MemorySegment instances.
class	ReadOnlySlicedNetworkBuffer Minimal best-effort read-only sliced Buffer implementation wrapping a NetworkBuffer's sub-region based on io.netty.buffer.SlicedByteBuf and io.netty.buffer.ReadOnlyByteBuf.

Methods in org.apache.flink.runtime.io.network.buffer that return Buffer

Modifier and Type	Method and Description
Buffer	BufferConsumer.build()
Buffer	Buffer.readOnlySlice() Returns a read-only slice of this buffer's readable bytes, i.e.
Buffer	Buffer.readOnlySlice(int index, int length) Returns a read-only slice of this buffer.
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.retainBuffer() Retains this buffer for further use, increasing the reference counter by 1.

Methods in org.apache.flink.runtime.io.network.buffer with parameters of type Buffer

Modifier and Type	Method and Description
boolean	BufferListener.notifyBufferAvailable(Buffer buffer) Notification callback if a buffer is recycled and becomes available in buffer pool.

Uses of Buffer in org.apache.flink.runtime.io.network.partition

Methods in org.apache.flink.runtime.io.network.partition that return Buffer

Modifier and Type	Method and Description
Buffer	ResultSubpartition.BufferAndBacklog.buffer()

Methods in org.apache.flink.runtime.io.network.partition with parameters of type Buffer

Modifier and Type	Method and Description
int	ResultSubpartition.decreaseBuffersInBacklog(Buffer buffer) Decreases the number of non-event buffers by one after fetching a non-event buffer from this subpartition (for access by the subpartition views).
protected void	ResultSubpartition.updateStatistics(Buffer buffer)

Constructors in org.apache.flink.runtime.io.network.partition with parameters of type Buffer

Constructor and Description
BufferAndBacklog(Buffer buffer, boolean isMoreAvailable, int buffersInBacklog, boolean nextBufferIsEvent)

Uses of Buffer in org.apache.flink.runtime.io.network.partition.consumer

Methods in org.apache.flink.runtime.io.network.partition.consumer that return Buffer

Modifier and Type	Method and Description
Buffer	InputChannel.BufferAndAvailability.buffer()
Buffer	BufferOrEvent.getBuffer()
Buffer	RemoteInputChannel.requestBuffer() Requests buffer from input channel directly for receiving network data.

Methods in org.apache.flink.runtime.io.network.partition.consumer with parameters of type Buffer

Modifier and Type	Method and Description
boolean	RemoteInputChannel.notifyBufferAvailable(Buffer buffer) The Buffer pool notifies this channel of an available floating buffer.
void	RemoteInputChannel.onBuffer(Buffer buffer, int sequenceNumber, int backlog)

Constructors in org.apache.flink.runtime.io.network.partition.consumer with parameters of type Buffer

Constructor and Description
BufferAndAvailability(Buffer buffer, boolean moreAvailable, int buffersInBacklog)
BufferOrEvent(Buffer buffer, int channelIndex)