Constructor and Description |
---|
BinaryHashTable(Configuration conf,
Object owner,
AbstractRowDataSerializer buildSideSerializer,
AbstractRowDataSerializer probeSideSerializer,
Projection<RowData,BinaryRowData> buildSideProjection,
Projection<RowData,BinaryRowData> probeSideProjection,
MemoryManager memManager,
long reservedMemorySize,
IOManager ioManager,
int avgRecordLen,
long buildRowCount,
boolean useBloomFilters,
HashJoinType type,
JoinCondition condFunc,
boolean reverseJoin,
boolean[] filterNulls,
boolean tryDistinctBuildRow) |
BinaryHashTable(Configuration conf,
Object owner,
AbstractRowDataSerializer buildSideSerializer,
AbstractRowDataSerializer probeSideSerializer,
Projection<RowData,BinaryRowData> buildSideProjection,
Projection<RowData,BinaryRowData> probeSideProjection,
MemoryManager memManager,
long reservedMemorySize,
IOManager ioManager,
int avgRecordLen,
long buildRowCount,
boolean useBloomFilters,
HashJoinType type,
JoinCondition condFunc,
boolean reverseJoin,
boolean[] filterNulls,
boolean tryDistinctBuildRow) |
Modifier and Type | Method and Description |
---|---|
SlicingWindowAggOperatorBuilder |
SlicingWindowAggOperatorBuilder.aggregate(GeneratedNamespaceAggsHandleFunction<Long> generatedAggregateFunction,
AbstractRowDataSerializer<RowData> accSerializer) |
SlicingWindowAggOperatorBuilder |
SlicingWindowAggOperatorBuilder.globalAggregate(GeneratedNamespaceAggsHandleFunction<Long> localGeneratedAggregateFunction,
GeneratedNamespaceAggsHandleFunction<Long> globalGeneratedAggregateFunction,
GeneratedNamespaceAggsHandleFunction<Long> stateGeneratedAggregateFunction,
AbstractRowDataSerializer<RowData> accSerializer) |
SlicingWindowAggOperatorBuilder |
SlicingWindowAggOperatorBuilder.inputSerializer(AbstractRowDataSerializer<RowData> inputSerializer) |
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.inputSerializer(AbstractRowDataSerializer<RowData> inputSerializer) |
Modifier and Type | Method and Description |
---|---|
WindowRankOperatorBuilder |
WindowRankOperatorBuilder.inputSerializer(AbstractRowDataSerializer<RowData> inputSerializer) |
Modifier and Type | Method and Description |
---|---|
static BinaryInMemorySortBuffer |
BinaryInMemorySortBuffer.createBuffer(NormalizedKeyComputer normalizedKeyComputer,
AbstractRowDataSerializer<RowData> inputSerializer,
BinaryRowDataSerializer serializer,
RecordComparator comparator,
MemorySegmentPool memoryPool)
Create a memory sorter in `insert` way.
|
Constructor and Description |
---|
BinaryExternalSorter(Object owner,
MemoryManager memoryManager,
long reservedMemorySize,
IOManager ioManager,
AbstractRowDataSerializer<RowData> inputSerializer,
BinaryRowDataSerializer serializer,
NormalizedKeyComputer normalizedKeyComputer,
RecordComparator comparator,
Configuration conf) |
BinaryExternalSorter(Object owner,
MemoryManager memoryManager,
long reservedMemorySize,
IOManager ioManager,
AbstractRowDataSerializer<RowData> inputSerializer,
BinaryRowDataSerializer serializer,
NormalizedKeyComputer normalizedKeyComputer,
RecordComparator comparator,
Configuration conf,
float startSpillingFraction) |
Modifier and Type | Class and Description |
---|---|
class |
BinaryRowDataSerializer
Serializer for
BinaryRowData . |
class |
RowDataSerializer
Serializer for
RowData . |
Constructor and Description |
---|
ResettableExternalBuffer(IOManager ioManager,
LazyMemorySegmentPool pool,
AbstractRowDataSerializer serializer,
boolean isRowAllInFixedPart) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.