Package org.apache.flink.runtime.io.network.buffer

Interface Summary

Interface	Description
Buffer	Wrapper for pooled MemorySegment instances with reference counting.
BufferListener	Interface of the availability of buffers.
BufferPool	A dynamically sized buffer pool.
BufferPoolFactory	A factory for buffer pools.
BufferPoolOwner	Interface for releasing memory buffers.
BufferProvider	A buffer provider to request buffers from in a synchronous or asynchronous fashion.
BufferReceivedListener	Interface of listener for notifying the received data buffer or checkpoint barrier from network channel.
BufferRecycler	Interface for recycling MemorySegments.

Class Summary

Class	Description
BufferBuilder	Not thread safe class for filling in the content of the MemorySegment.
BufferCompressor	Compressor for Buffer.
BufferConsumer	Not thread safe class for producing Buffer.
BufferDecompressor	Decompressor for compressed Buffer.
FreeingBufferRecycler	A simple buffer recycler that frees the memory segments.
NetworkBuffer	Wrapper for pooled MemorySegment instances.
NetworkBufferPool	The NetworkBufferPool is a fixed size pool of MemorySegment instances for the network stack.
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.

Enum Summary

Enum	Description
Buffer.DataType	Used to identify the type of data contained in the Buffer so that we can get the information without deserializing the serialized data.
BufferListener.NotificationResult	Status of the notification result from the buffer listener.