Uses of Class
org.apache.flink.table.runtime.generated.GeneratedAggsHandleFunction
-
-
Uses of GeneratedAggsHandleFunction in org.apache.flink.table.runtime.operators.aggregate
Constructors in org.apache.flink.table.runtime.operators.aggregate with parameters of type GeneratedAggsHandleFunction Constructor Description GroupAggFunction(GeneratedAggsHandleFunction genAggsHandler, GeneratedRecordEqualiser genRecordEqualiser, org.apache.flink.table.types.logical.LogicalType[] accTypes, int indexOfCountStar, boolean generateUpdateBefore, long stateRetentionTime)Creates aGroupAggFunction.MiniBatchGlobalGroupAggFunction(GeneratedAggsHandleFunction genLocalAggsHandler, GeneratedAggsHandleFunction genGlobalAggsHandler, GeneratedRecordEqualiser genRecordEqualiser, org.apache.flink.table.types.logical.LogicalType[] accTypes, int indexOfCountStar, boolean generateUpdateBefore, long stateRetentionTime)Creates aMiniBatchGlobalGroupAggFunction.MiniBatchGroupAggFunction(GeneratedAggsHandleFunction genAggsHandler, GeneratedRecordEqualiser genRecordEqualiser, org.apache.flink.table.types.logical.LogicalType[] accTypes, org.apache.flink.table.types.logical.RowType inputType, int indexOfCountStar, boolean generateUpdateBefore, long stateRetentionTime)Creates aMiniBatchGroupAggFunction.MiniBatchIncrementalGroupAggFunction(GeneratedAggsHandleFunction genPartialAggsHandler, GeneratedAggsHandleFunction genFinalAggsHandler, org.apache.flink.api.java.functions.KeySelector<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData> finalKeySelector, long stateRetentionTime)MiniBatchLocalGroupAggFunction(GeneratedAggsHandleFunction genAggsHandler) -
Uses of GeneratedAggsHandleFunction in org.apache.flink.table.runtime.operators.over
Constructors in org.apache.flink.table.runtime.operators.over with parameters of type GeneratedAggsHandleFunction Constructor Description AbstractRowTimeUnboundedPrecedingOver(long minRetentionTime, long maxRetentionTime, GeneratedAggsHandleFunction genAggsHandler, org.apache.flink.table.types.logical.LogicalType[] accTypes, org.apache.flink.table.types.logical.LogicalType[] inputFieldTypes, int rowTimeIdx)NonBufferOverWindowOperator(GeneratedAggsHandleFunction[] aggsHandlers, GeneratedRecordComparator genComparator, boolean[] resetAccumulators)ProcTimeRangeBoundedPrecedingFunction(GeneratedAggsHandleFunction genAggsHandler, org.apache.flink.table.types.logical.LogicalType[] accTypes, org.apache.flink.table.types.logical.LogicalType[] inputFieldTypes, long precedingTimeBoundary)ProcTimeRowsBoundedPrecedingFunction(long minRetentionTime, long maxRetentionTime, GeneratedAggsHandleFunction genAggsHandler, org.apache.flink.table.types.logical.LogicalType[] accTypes, org.apache.flink.table.types.logical.LogicalType[] inputFieldTypes, long precedingOffset)ProcTimeUnboundedPrecedingFunction(org.apache.flink.api.common.state.StateTtlConfig ttlConfig, GeneratedAggsHandleFunction genAggsHandler, org.apache.flink.table.types.logical.LogicalType[] accTypes)RowTimeRangeBoundedPrecedingFunction(GeneratedAggsHandleFunction genAggsHandler, org.apache.flink.table.types.logical.LogicalType[] accTypes, org.apache.flink.table.types.logical.LogicalType[] inputFieldTypes, long precedingOffset, int rowTimeIdx)RowTimeRangeUnboundedPrecedingFunction(long minRetentionTime, long maxRetentionTime, GeneratedAggsHandleFunction genAggsHandler, org.apache.flink.table.types.logical.LogicalType[] accTypes, org.apache.flink.table.types.logical.LogicalType[] inputFieldTypes, int rowTimeIdx)RowTimeRowsBoundedPrecedingFunction(long minRetentionTime, long maxRetentionTime, GeneratedAggsHandleFunction genAggsHandler, org.apache.flink.table.types.logical.LogicalType[] accTypes, org.apache.flink.table.types.logical.LogicalType[] inputFieldTypes, long precedingOffset, int rowTimeIdx)RowTimeRowsUnboundedPrecedingFunction(long minRetentionTime, long maxRetentionTime, GeneratedAggsHandleFunction genAggsHandler, org.apache.flink.table.types.logical.LogicalType[] accTypes, org.apache.flink.table.types.logical.LogicalType[] inputFieldTypes, int rowTimeIdx) -
Uses of GeneratedAggsHandleFunction in org.apache.flink.table.runtime.operators.over.frame
Constructors in org.apache.flink.table.runtime.operators.over.frame with parameters of type GeneratedAggsHandleFunction Constructor Description InsensitiveOverFrame(GeneratedAggsHandleFunction aggsHandleFunction)OffsetOverFrame(GeneratedAggsHandleFunction aggsHandleFunction, Long offset, OffsetOverFrame.CalcOffsetFunc calcOffsetFunc)RangeSlidingOverFrame(org.apache.flink.table.types.logical.RowType inputType, org.apache.flink.table.types.logical.RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction, GeneratedRecordComparator lboundComparator, GeneratedRecordComparator rboundComparator)RangeUnboundedFollowingOverFrame(org.apache.flink.table.types.logical.RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction, GeneratedRecordComparator boundComparator)RangeUnboundedPrecedingOverFrame(GeneratedAggsHandleFunction aggsHandleFunction, GeneratedRecordComparator boundComparator)RowSlidingOverFrame(org.apache.flink.table.types.logical.RowType inputType, org.apache.flink.table.types.logical.RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction, long leftBound, long rightBound)RowUnboundedFollowingOverFrame(org.apache.flink.table.types.logical.RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction, long leftBound)RowUnboundedPrecedingOverFrame(GeneratedAggsHandleFunction aggsHandleFunction, long rightBound)SlidingOverFrame(org.apache.flink.table.types.logical.RowType inputType, org.apache.flink.table.types.logical.RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction)UnboundedFollowingOverFrame(org.apache.flink.table.types.logical.RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction)UnboundedOverWindowFrame(GeneratedAggsHandleFunction aggsHandleFunction, org.apache.flink.table.types.logical.RowType valueType)UnboundedPrecedingOverFrame(GeneratedAggsHandleFunction aggsHandleFunction)
-