Uses of Class
org.apache.flink.table.runtime.typeutils.PagedTypeSerializer
-
-
Uses of PagedTypeSerializer in org.apache.flink.table.runtime.operators.aggregate.window
Methods in org.apache.flink.table.runtime.operators.aggregate.window with parameters of type PagedTypeSerializer Modifier and Type Method Description SlicingWindowAggOperatorBuilderSlicingWindowAggOperatorBuilder. keySerializer(PagedTypeSerializer<org.apache.flink.table.data.RowData> keySerializer) -
Uses of PagedTypeSerializer in org.apache.flink.table.runtime.operators.aggregate.window.buffers
Constructors in org.apache.flink.table.runtime.operators.aggregate.window.buffers with parameters of type PagedTypeSerializer Constructor Description Factory(PagedTypeSerializer<org.apache.flink.table.data.RowData> keySer, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSer, RecordsCombiner.Factory combinerFactory)LocalFactory(PagedTypeSerializer<org.apache.flink.table.data.RowData> keySer, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSer, RecordsCombiner.LocalFactory localFactory)RecordsWindowBuffer(Object operatorOwner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, RecordsCombiner combineFunction, PagedTypeSerializer<org.apache.flink.table.data.RowData> keySer, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSer, boolean requiresCopy, java.time.ZoneId shiftTimeZone) -
Uses of PagedTypeSerializer in org.apache.flink.table.runtime.operators.deduplicate.window
Methods in org.apache.flink.table.runtime.operators.deduplicate.window with parameters of type PagedTypeSerializer Modifier and Type Method Description RowTimeWindowDeduplicateOperatorBuilderRowTimeWindowDeduplicateOperatorBuilder. keySerializer(PagedTypeSerializer<org.apache.flink.table.data.RowData> keySerializer) -
Uses of PagedTypeSerializer in org.apache.flink.table.runtime.operators.rank.window
Methods in org.apache.flink.table.runtime.operators.rank.window with parameters of type PagedTypeSerializer Modifier and Type Method Description WindowRankOperatorBuilderWindowRankOperatorBuilder. keySerializer(PagedTypeSerializer<org.apache.flink.table.data.RowData> keySerializer) -
Uses of PagedTypeSerializer in org.apache.flink.table.runtime.typeutils
Subclasses of PagedTypeSerializer in org.apache.flink.table.runtime.typeutils Modifier and Type Class Description classAbstractRowDataSerializer<T extends org.apache.flink.table.data.RowData>Row serializer, provided paged serialize paged method.classBinaryRowDataSerializerSerializer forBinaryRowData.classRowDataSerializerSerializer forRowData.classWindowKeySerializerSerializer forWindowKeywhich is composite with aBinaryRowDataand a long value.Constructors in org.apache.flink.table.runtime.typeutils with parameters of type PagedTypeSerializer Constructor Description WindowKeySerializer(PagedTypeSerializer<org.apache.flink.table.data.RowData> keySerializer) -
Uses of PagedTypeSerializer in org.apache.flink.table.runtime.util.collections.binary
Fields in org.apache.flink.table.runtime.util.collections.binary declared as PagedTypeSerializer Modifier and Type Field Description protected PagedTypeSerializer<K>AbstractBytesHashMap. keySerializerUsed to serialize map key into RecordArea's MemorySegments.protected PagedTypeSerializer<K>AbstractBytesMultiMap. keySerializerUsed to serialize map key into RecordArea's MemorySegments.Constructors in org.apache.flink.table.runtime.util.collections.binary with parameters of type PagedTypeSerializer Constructor Description AbstractBytesHashMap(Object owner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, PagedTypeSerializer<K> keySerializer, int valueArity)AbstractBytesHashMap(Object owner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, PagedTypeSerializer<K> keySerializer, org.apache.flink.table.types.logical.LogicalType[] valueTypes)AbstractBytesMultiMap(Object owner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, PagedTypeSerializer<K> keySerializer, int valueArity)AbstractBytesMultiMap(Object owner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, PagedTypeSerializer<K> keySerializer, org.apache.flink.table.types.logical.LogicalType[] valueTypes)WindowBytesHashMap(Object owner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, PagedTypeSerializer<org.apache.flink.table.data.RowData> keySer, int valueArity)WindowBytesMultiMap(Object owner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, PagedTypeSerializer<org.apache.flink.table.data.RowData> keySer, int valueArity)
-