Class BytesHashMapSpillMemorySegmentPool
- java.lang.Object
-
- org.apache.flink.table.runtime.operators.aggregate.BytesHashMapSpillMemorySegmentPool
-
- All Implemented Interfaces:
org.apache.flink.core.memory.MemorySegmentSource,MemorySegmentPool
public class BytesHashMapSpillMemorySegmentPool extends Object implements MemorySegmentPool
MemorySegmentPool forBytesHashMapto fall back to sort agg.nextSegment()not remove segment from segments, just get from segments.
-
-
Constructor Summary
Constructors Constructor Description BytesHashMapSpillMemorySegmentPool(List<org.apache.flink.core.memory.MemorySegment> memorySegments)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description intfreePages()org.apache.flink.core.memory.MemorySegmentnextSegment()intpageSize()Get the page size of each page this pool holds.voidreturnAll(List<org.apache.flink.core.memory.MemorySegment> memory)Return all pages back into this pool.
-
-
-
Constructor Detail
-
BytesHashMapSpillMemorySegmentPool
public BytesHashMapSpillMemorySegmentPool(List<org.apache.flink.core.memory.MemorySegment> memorySegments)
-
-
Method Detail
-
nextSegment
public org.apache.flink.core.memory.MemorySegment nextSegment()
- Specified by:
nextSegmentin interfaceorg.apache.flink.core.memory.MemorySegmentSource
-
returnAll
public void returnAll(List<org.apache.flink.core.memory.MemorySegment> memory)
Description copied from interface:MemorySegmentPoolReturn all pages back into this pool.- Specified by:
returnAllin interfaceMemorySegmentPool- Parameters:
memory- the pages which want to be returned.
-
freePages
public int freePages()
- Specified by:
freePagesin interfaceMemorySegmentPool- Returns:
- Free page number.
-
pageSize
public int pageSize()
Description copied from interface:MemorySegmentPoolGet the page size of each page this pool holds.- Specified by:
pageSizein interfaceMemorySegmentPool- Returns:
- the page size
-
-