Uses of Class
org.apache.flink.table.runtime.generated.GeneratedAggsHandleFunction

Packages that use GeneratedAggsHandleFunction

Package	Description
org.apache.flink.table.runtime.operators.aggregate
org.apache.flink.table.runtime.operators.over
org.apache.flink.table.runtime.operators.over.frame

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 and Description
GroupAggFunction(GeneratedAggsHandleFunction genAggsHandler, GeneratedRecordEqualiser genRecordEqualiser, LogicalType[] accTypes, int indexOfCountStar, boolean generateUpdateBefore, long stateRetentionTime) Creates a GroupAggFunction.
MiniBatchGlobalGroupAggFunction(GeneratedAggsHandleFunction genLocalAggsHandler, GeneratedAggsHandleFunction genGlobalAggsHandler, GeneratedRecordEqualiser genRecordEqualiser, LogicalType[] accTypes, int indexOfCountStar, boolean generateUpdateBefore, long stateRetentionTime) Creates a MiniBatchGlobalGroupAggFunction.
MiniBatchGroupAggFunction(GeneratedAggsHandleFunction genAggsHandler, GeneratedRecordEqualiser genRecordEqualiser, LogicalType[] accTypes, RowType inputType, int indexOfCountStar, boolean generateUpdateBefore, long stateRetentionTime) Creates a MiniBatchGroupAggFunction.
MiniBatchIncrementalGroupAggFunction(GeneratedAggsHandleFunction genPartialAggsHandler, GeneratedAggsHandleFunction genFinalAggsHandler, KeySelector<RowData,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 and Description
AbstractRowTimeUnboundedPrecedingOver(long minRetentionTime, long maxRetentionTime, GeneratedAggsHandleFunction genAggsHandler, LogicalType[] accTypes, LogicalType[] inputFieldTypes, int rowTimeIdx)
NonBufferOverWindowOperator(GeneratedAggsHandleFunction[] aggsHandlers, GeneratedRecordComparator genComparator, boolean[] resetAccumulators)
ProcTimeRangeBoundedPrecedingFunction(GeneratedAggsHandleFunction genAggsHandler, LogicalType[] accTypes, LogicalType[] inputFieldTypes, long precedingTimeBoundary)
ProcTimeRowsBoundedPrecedingFunction(long minRetentionTime, long maxRetentionTime, GeneratedAggsHandleFunction genAggsHandler, LogicalType[] accTypes, LogicalType[] inputFieldTypes, long precedingOffset)
ProcTimeUnboundedPrecedingFunction(StateTtlConfig ttlConfig, GeneratedAggsHandleFunction genAggsHandler, LogicalType[] accTypes)
RowTimeRangeBoundedPrecedingFunction(GeneratedAggsHandleFunction genAggsHandler, LogicalType[] accTypes, LogicalType[] inputFieldTypes, long precedingOffset, int rowTimeIdx)
RowTimeRangeUnboundedPrecedingFunction(long minRetentionTime, long maxRetentionTime, GeneratedAggsHandleFunction genAggsHandler, LogicalType[] accTypes, LogicalType[] inputFieldTypes, int rowTimeIdx)
RowTimeRowsBoundedPrecedingFunction(long minRetentionTime, long maxRetentionTime, GeneratedAggsHandleFunction genAggsHandler, LogicalType[] accTypes, LogicalType[] inputFieldTypes, long precedingOffset, int rowTimeIdx)
RowTimeRowsUnboundedPrecedingFunction(long minRetentionTime, long maxRetentionTime, GeneratedAggsHandleFunction genAggsHandler, LogicalType[] accTypes, 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 and Description
InsensitiveOverFrame(GeneratedAggsHandleFunction aggsHandleFunction)
OffsetOverFrame(GeneratedAggsHandleFunction aggsHandleFunction, Long offset, OffsetOverFrame.CalcOffsetFunc calcOffsetFunc)
RangeSlidingOverFrame(RowType inputType, RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction, GeneratedRecordComparator lboundComparator, GeneratedRecordComparator rboundComparator)
RangeUnboundedFollowingOverFrame(RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction, GeneratedRecordComparator boundComparator)
RangeUnboundedPrecedingOverFrame(GeneratedAggsHandleFunction aggsHandleFunction, GeneratedRecordComparator boundComparator)
RowSlidingOverFrame(RowType inputType, RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction, long leftBound, long rightBound)
RowUnboundedFollowingOverFrame(RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction, long leftBound)
RowUnboundedPrecedingOverFrame(GeneratedAggsHandleFunction aggsHandleFunction, long rightBound)
SlidingOverFrame(RowType inputType, RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction)
UnboundedFollowingOverFrame(RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction)
UnboundedOverWindowFrame(GeneratedAggsHandleFunction aggsHandleFunction, RowType valueType)
UnboundedPrecedingOverFrame(GeneratedAggsHandleFunction aggsHandleFunction)