Modifier and Type | Method and Description |
---|---|
SlicingWindowAggOperatorBuilder |
SlicingWindowAggOperatorBuilder.keySerializer(PagedTypeSerializer<RowData> keySerializer) |
Constructor and Description |
---|
Factory(PagedTypeSerializer<RowData> keySer,
AbstractRowDataSerializer<RowData> inputSer,
RecordsCombiner.Factory combinerFactory) |
LocalFactory(PagedTypeSerializer<RowData> keySer,
AbstractRowDataSerializer<RowData> inputSer,
RecordsCombiner.LocalFactory localFactory) |
RecordsWindowBuffer(Object operatorOwner,
MemoryManager memoryManager,
long memorySize,
RecordsCombiner combineFunction,
PagedTypeSerializer<RowData> keySer,
AbstractRowDataSerializer<RowData> inputSer,
boolean requiresCopy,
java.time.ZoneId shiftTimeZone) |
Modifier and Type | Method and Description |
---|---|
RowTimeWindowDeduplicateOperatorBuilder |
RowTimeWindowDeduplicateOperatorBuilder.keySerializer(PagedTypeSerializer<RowData> keySerializer) |
Modifier and Type | Method and Description |
---|---|
WindowRankOperatorBuilder |
WindowRankOperatorBuilder.keySerializer(PagedTypeSerializer<RowData> keySerializer) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractRowDataSerializer<T extends RowData>
Row serializer, provided paged serialize paged method.
|
class |
BinaryRowDataSerializer
Serializer for
BinaryRowData . |
class |
RowDataSerializer
Serializer for
RowData . |
class |
WindowKeySerializer
Serializer for
WindowKey which is composite with a BinaryRowData and a long
value. |
Constructor and Description |
---|
WindowKeySerializer(PagedTypeSerializer<RowData> keySerializer) |
Modifier and Type | Field and Description |
---|---|
protected PagedTypeSerializer<K> |
AbstractBytesMultiMap.keySerializer
Used to serialize map key into RecordArea's MemorySegments.
|
protected PagedTypeSerializer<K> |
AbstractBytesHashMap.keySerializer
Used to serialize map key into RecordArea's MemorySegments.
|
Constructor and Description |
---|
AbstractBytesHashMap(Object owner,
MemoryManager memoryManager,
long memorySize,
PagedTypeSerializer<K> keySerializer,
int valueArity) |
AbstractBytesHashMap(Object owner,
MemoryManager memoryManager,
long memorySize,
PagedTypeSerializer<K> keySerializer,
LogicalType[] valueTypes) |
AbstractBytesMultiMap(Object owner,
MemoryManager memoryManager,
long memorySize,
PagedTypeSerializer<K> keySerializer,
int valueArity) |
AbstractBytesMultiMap(Object owner,
MemoryManager memoryManager,
long memorySize,
PagedTypeSerializer<K> keySerializer,
LogicalType[] valueTypes) |
WindowBytesHashMap(Object owner,
MemoryManager memoryManager,
long memorySize,
PagedTypeSerializer<RowData> keySer,
int valueArity) |
WindowBytesMultiMap(Object owner,
MemoryManager memoryManager,
long memorySize,
PagedTypeSerializer<RowData> keySer,
int valueArity) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.