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.
BufferProvider	A buffer provider to request buffers from in a synchronous or asynchronous fashion.
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.
BufferConsumerWithPartialRecordLength	BufferConsumer with partial record length if a record is spanning over buffers `partialRecordLength` is the length of bytes to skip in order to start with a complete record, from position index 0 of the underlying MemorySegment.
BufferDecompressor	Decompressor for compressed Buffer.
BufferHeader	Header fields of a Buffer.
BufferRecycler.DummyBufferRecycler	The buffer recycler does nothing for recycled segment.
CompositeBuffer	An implementation of Buffer which contains multiple partial buffers for network data communication.
FileRegionBuffer	This class represents a chunk of data in a file channel.
FreeingBufferRecycler	A simple buffer recycler that frees the memory segments.
LocalBufferPool	A buffer pool used to manage a number of Buffer instances from the NetworkBufferPool.
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.