Uses of Interface
org.apache.paimon.memory.MemorySegmentPool

Packages that use MemorySegmentPool

Package	Description
org.apache.paimon.append
org.apache.paimon.disk
org.apache.paimon.flink.memory
org.apache.paimon.flink.sink
org.apache.paimon.memory
org.apache.paimon.mergetree
org.apache.paimon.operation
org.apache.paimon.sort
org.apache.paimon.table.sink

Uses of MemorySegmentPool in org.apache.paimon.append

Methods in org.apache.paimon.append with parameters of type MemorySegmentPool

Modifier and Type	Method and Description
void	AppendOnlyWriter.setMemoryPool(MemorySegmentPool memoryPool)

Uses of MemorySegmentPool in org.apache.paimon.disk

Methods in org.apache.paimon.disk with parameters of type MemorySegmentPool

Modifier and Type	Method and Description
static RowBuffer	RowBuffer.getBuffer(IOManager ioManager, MemorySegmentPool memoryPool, AbstractRowDataSerializer<InternalRow> serializer, boolean spillable, MemorySize maxDiskSize, CompressOptions compression)

Uses of MemorySegmentPool in org.apache.paimon.flink.memory

Classes in org.apache.paimon.flink.memory that implement MemorySegmentPool

Modifier and Type	Class and Description
class	FlinkMemorySegmentPool Flink memory segment pool allocates segment from flink managed memory for paimon writer buffer.

Uses of MemorySegmentPool in org.apache.paimon.flink.sink

Fields in org.apache.paimon.flink.sink declared as MemorySegmentPool

Modifier and Type	Field and Description
protected MemorySegmentPool	PrepareCommitOperator.memoryPool

Methods in org.apache.paimon.flink.sink with parameters of type MemorySegmentPool

Modifier and Type	Method and Description
StoreSinkWrite	StoreSinkWrite.Provider.provide(FileStoreTable table, String commitUser, StoreSinkWriteState state, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, MemorySegmentPool memoryPool, org.apache.flink.metrics.MetricGroup metricGroup)

Constructors in org.apache.paimon.flink.sink with parameters of type MemorySegmentPool

Constructor and Description
AsyncLookupSinkWrite(FileStoreTable table, String commitUser, StoreSinkWriteState state, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, boolean ignorePreviousFiles, boolean waitCompaction, boolean isStreaming, MemorySegmentPool memoryPool, org.apache.flink.metrics.MetricGroup metricGroup)
GlobalFullCompactionSinkWrite(FileStoreTable table, String commitUser, StoreSinkWriteState state, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, boolean ignorePreviousFiles, boolean waitCompaction, int deltaCommits, boolean isStreaming, MemorySegmentPool memoryPool, org.apache.flink.metrics.MetricGroup metricGroup)
StoreSinkWriteImpl(FileStoreTable table, String commitUser, StoreSinkWriteState state, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, boolean ignorePreviousFiles, boolean waitCompaction, boolean isStreamingMode, MemorySegmentPool memoryPool, org.apache.flink.metrics.MetricGroup metricGroup)

Uses of MemorySegmentPool in org.apache.paimon.memory

Classes in org.apache.paimon.memory that implement MemorySegmentPool

Modifier and Type	Class and Description
class	AbstractMemorySegmentPool Abstract memory segment pool.
class	ArraySegmentPool A MemorySegmentPool for allocated segments.
class	CachelessSegmentPool A MemorySegmentPool without cache.
class	HeapMemorySegmentPool MemorySegment pool from heap.

Methods in org.apache.paimon.memory that return MemorySegmentPool

Modifier and Type	Method and Description
static MemorySegmentPool	MemorySegmentPool.createHeapPool(MemorySize maxMemory, MemorySize pageSize)

Methods in org.apache.paimon.memory with parameters of type MemorySegmentPool

Modifier and Type	Method and Description
void	MemoryOwner.setMemoryPool(MemorySegmentPool memoryPool) Set MemorySegmentPool for the owner.

Constructors in org.apache.paimon.memory with parameters of type MemorySegmentPool

Constructor and Description
MemoryPoolFactory(MemorySegmentPool innerPool)

Uses of MemorySegmentPool in org.apache.paimon.mergetree

Methods in org.apache.paimon.mergetree that return MemorySegmentPool

Modifier and Type	Method and Description
MemorySegmentPool	MergeSorter.memoryPool()

Methods in org.apache.paimon.mergetree with parameters of type MemorySegmentPool

Modifier and Type	Method and Description
void	MergeTreeWriter.setMemoryPool(MemorySegmentPool memoryPool)

Constructors in org.apache.paimon.mergetree with parameters of type MemorySegmentPool

Constructor and Description
SortBufferWriteBuffer(RowType keyType, RowType valueType, FieldsComparator userDefinedSeqComparator, MemorySegmentPool memoryPool, boolean spillable, MemorySize maxDiskSize, int sortMaxFan, CompressOptions compression, IOManager ioManager)

Uses of MemorySegmentPool in org.apache.paimon.operation

Methods in org.apache.paimon.operation with parameters of type MemorySegmentPool

Modifier and Type	Method and Description
default FileStoreWrite<T>	FileStoreWrite.withMemoryPool(MemorySegmentPool memoryPool) With memory pool for the current file store write.

Uses of MemorySegmentPool in org.apache.paimon.sort

Fields in org.apache.paimon.sort declared as MemorySegmentPool

Modifier and Type	Field and Description
protected MemorySegmentPool	BinaryIndexedSortable.memorySegmentPool

Methods in org.apache.paimon.sort with parameters of type MemorySegmentPool

Modifier and Type	Method and Description
static BinaryExternalSortBuffer	BinaryExternalSortBuffer.create(IOManager ioManager, RowType rowType, int[] keyFields, MemorySegmentPool pool, int maxNumFileHandles, CompressOptions compression, MemorySize maxDiskSize)
static BinaryInMemorySortBuffer	BinaryInMemorySortBuffer.createBuffer(NormalizedKeyComputer normalizedKeyComputer, AbstractRowDataSerializer<InternalRow> serializer, RecordComparator comparator, MemorySegmentPool memoryPool) Create a memory sorter in `insert` way.

Constructors in org.apache.paimon.sort with parameters of type MemorySegmentPool

Constructor and Description
BinaryIndexedSortable(NormalizedKeyComputer normalizedKeyComputer, BinaryRowSerializer serializer, RecordComparator comparator, ArrayList<MemorySegment> recordBufferSegments, MemorySegmentPool memorySegmentPool)

Uses of MemorySegmentPool in org.apache.paimon.table.sink

Methods in org.apache.paimon.table.sink with parameters of type MemorySegmentPool

Modifier and Type	Method and Description
TableWrite	TableWrite.withMemoryPool(MemorySegmentPool memoryPool) With MemorySegmentPool for the current table write.
TableWriteImpl<T>	TableWriteImpl.withMemoryPool(MemorySegmentPool memoryPool)