org.apache.paimon.memory

Class AbstractMemorySegmentPool

java.lang.Object

org.apache.paimon.memory.AbstractMemorySegmentPool

All Implemented Interfaces:

MemorySegmentPool, MemorySegmentSource

Direct Known Subclasses:

FlinkMemorySegmentPool, HeapMemorySegmentPool

public abstract class AbstractMemorySegmentPool
extends Object
implements MemorySegmentPool

Abstract memory segment pool.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	pageSize

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

DEFAULT_PAGE_SIZE

Constructor Summary

Constructors

Constructor and Description
AbstractMemorySegmentPool(long maxMemory, int pageSize)

Method Summary

Modifier and Type	Method and Description
protected abstract MemorySegment	allocateMemory()
int	freePages()
MemorySegment	nextSegment() Gets the next memory segment.
int	pageSize() Get the page size of each page this pool holds.
void	returnAll(List<MemorySegment> memory) Return all pages back into this pool.

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

Field Detail

pageSize

protected final int pageSize

Constructor Detail

AbstractMemorySegmentPool

public AbstractMemorySegmentPool(long maxMemory,
                                 int pageSize)

Method Detail

nextSegment

public MemorySegment nextSegment()

Description copied from interface: MemorySegmentSource

Gets the next memory segment. If no more segments are available, it returns null.

Specified by:

nextSegment in interface MemorySegmentSource

Returns:

The next memory segment, or null, if none is available.

allocateMemory

protected abstract MemorySegment allocateMemory()

pageSize

public int pageSize()

Description copied from interface: MemorySegmentPool

Get the page size of each page this pool holds.

Specified by:

pageSize in interface MemorySegmentPool

Returns:

the page size, the bytes size in one page.

returnAll

public void returnAll(List<MemorySegment> memory)

Description copied from interface: MemorySegmentPool

Return all pages back into this pool.

Specified by:

returnAll in interface MemorySegmentPool

Parameters:

memory - the pages which want to be returned.

freePages

public int freePages()

Specified by:

freePages in interface MemorySegmentPool

Returns:

Free page number.