Package org.apache.flink.table.runtime.util.collections.binary

Class WindowBytesMultiMap

java.lang.Object

org.apache.flink.table.runtime.util.collections.binary.BytesMap<K,Iterator<org.apache.flink.table.data.RowData>>

org.apache.flink.table.runtime.util.collections.binary.AbstractBytesMultiMap<WindowKey>

org.apache.flink.table.runtime.util.collections.binary.WindowBytesMultiMap

public final class WindowBytesMultiMap
extends AbstractBytesMultiMap<WindowKey>

A binary map in the structure like Map<WindowKey, List<BinaryRowData>>.

See Also:

for more information about the binary layout.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.table.runtime.util.collections.binary.BytesMap

BytesMap.LookupInfo<K,V>

Field Summary

Fields inherited from class org.apache.flink.table.runtime.util.collections.binary.AbstractBytesMultiMap

keySerializer

Fields inherited from class org.apache.flink.table.runtime.util.collections.binary.BytesMap

BUCKET_SIZE, BUCKET_SIZE_BITS, bucketSegments, ELEMENT_POINT_LENGTH, END_OF_LIST, growthThreshold, INIT_BUCKET_MEMORY_IN_BYTES, lastBucketPosition, LOAD_FACTOR, log2NumBuckets, memoryPool, numBucketsMask, numBucketsMask2, numBucketsPerSegment, numBucketsPerSegmentBits, numBucketsPerSegmentMask, numElements, numSpillFiles, RECORD_EXTRA_LENGTH, recordArea, reservedNumBuffers, reusedKey, reusedValue, segmentSize, spillInBytes, STEP_INCREMENT

Constructor Summary

Constructors

Constructor	Description
WindowBytesMultiMap(Object owner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, PagedTypeSerializer<org.apache.flink.table.data.RowData> keySer, int valueArity)

Method Summary

Methods inherited from class org.apache.flink.table.runtime.util.collections.binary.AbstractBytesMultiMap

append, free, free, getEntryIterator, getNumKeys, reset

Methods inherited from class org.apache.flink.table.runtime.util.collections.binary.BytesMap

calcSecondHashCode, getNumElements, getNumSpillFiles, getSpillInBytes, growAndRehash, initBucketSegments, lookup, resetBucketSegments, returnSegments

Methods inherited from class java.lang.Object

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

Constructor Detail

WindowBytesMultiMap

public WindowBytesMultiMap(Object owner,
                           org.apache.flink.runtime.memory.MemoryManager memoryManager,
                           long memorySize,
                           PagedTypeSerializer<org.apache.flink.table.data.RowData> keySer,
                           int valueArity)