Package | Description |
---|---|
org.apache.flink.runtime.io.network.buffer | |
org.apache.flink.runtime.io.network.partition.consumer | |
org.apache.flink.table.runtime.io |
Modifier and Type | Interface and Description |
---|---|
interface |
BufferPool
A dynamically sized buffer pool.
|
Modifier and Type | Class and Description |
---|---|
static class |
BufferRecycler.DummyBufferRecycler
The buffer recycler does nothing for recycled segment.
|
class |
FreeingBufferRecycler
A simple buffer recycler that frees the memory segments.
|
Modifier and Type | Field and Description |
---|---|
static BufferRecycler |
FreeingBufferRecycler.INSTANCE |
static BufferRecycler |
BufferRecycler.DummyBufferRecycler.INSTANCE |
Modifier and Type | Method and Description |
---|---|
BufferRecycler |
NetworkBuffer.getRecycler() |
BufferRecycler |
ReadOnlySlicedNetworkBuffer.getRecycler() |
BufferRecycler |
FileRegionBuffer.getRecycler() |
BufferRecycler |
Buffer.getRecycler()
Gets the buffer's recycler.
|
Constructor and Description |
---|
BufferBuilder(MemorySegment memorySegment,
BufferRecycler recycler) |
NetworkBuffer(MemorySegment memorySegment,
BufferRecycler recycler)
Creates a new buffer instance backed by the given memorySegment with 0 for
the readerIndex and writerIndex.
|
NetworkBuffer(MemorySegment memorySegment,
BufferRecycler recycler,
Buffer.DataType dataType)
Creates a new buffer instance backed by the given memorySegment with 0 for
the readerIndex and writerIndex.
|
NetworkBuffer(MemorySegment memorySegment,
BufferRecycler recycler,
Buffer.DataType dataType,
boolean isCompressed,
int size)
Creates a new buffer instance backed by the given memorySegment with 0 for
the readerIndex and size as writerIndex.
|
NetworkBuffer(MemorySegment memorySegment,
BufferRecycler recycler,
Buffer.DataType dataType,
int size)
Creates a new buffer instance backed by the given memorySegment with 0 for
the readerIndex and size as writerIndex.
|
Modifier and Type | Class and Description |
---|---|
class |
BufferManager
The general buffer manager used by
InputChannel to request/recycle exclusive or floating
buffers. |
Modifier and Type | Class and Description |
---|---|
class |
CompressedBlockChannelReader
Compressed block channel reader provides a scenario where MemorySegment must be maintained.
|
class |
CompressedBlockChannelWriter
Compressed block channel writer provides a scenario where MemorySegment must be maintained.
|
class |
CompressedHeaderlessChannelReaderInputView
A
DataInputView that is backed by a BufferFileReader , making it effectively a data input stream. |
class |
CompressedHeaderlessChannelWriterOutputView
A
DataOutputView that is backed by a FileIOChannel ,
making it effectively a data output stream. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.