org.apache.paimon.flink.memory

Class FlinkMemorySegmentPool

java.lang.Object

org.apache.paimon.memory.AbstractMemorySegmentPool

org.apache.paimon.flink.memory.FlinkMemorySegmentPool

All Implemented Interfaces:

MemorySegmentPool, MemorySegmentSource

public class FlinkMemorySegmentPool
extends AbstractMemorySegmentPool

Flink memory segment pool allocates segment from flink managed memory for paimon writer buffer.

Field Summary

Fields inherited from class org.apache.paimon.memory.AbstractMemorySegmentPool

pageSize

Fields inherited from interface org.apache.paimon.memory.MemorySegmentPool

DEFAULT_PAGE_SIZE

Constructor Summary

Constructors

Constructor and Description
FlinkMemorySegmentPool(long maxMemory, int pageSize, MemorySegmentAllocator allocator)

Method Summary

Modifier and Type	Method and Description
protected MemorySegment	allocateMemory()

Methods inherited from class org.apache.paimon.memory.AbstractMemorySegmentPool

freePages, nextSegment, pageSize, returnAll

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.paimon.memory.MemorySegmentPool

createHeapPool

Constructor Detail

FlinkMemorySegmentPool

public FlinkMemorySegmentPool(long maxMemory,
                              int pageSize,
                              MemorySegmentAllocator allocator)

Method Detail

allocateMemory

protected MemorySegment allocateMemory()

Specified by:

allocateMemory in class AbstractMemorySegmentPool