Uses of Class
org.apache.flink.table.runtime.operators.aggregate.RecordCounter

Packages that use RecordCounter

Package	Description
org.apache.flink.table.runtime.operators.aggregate
org.apache.flink.table.runtime.operators.aggregate.utils
org.apache.flink.table.runtime.operators.window.groupwindow.operator

Uses of RecordCounter in org.apache.flink.table.runtime.operators.aggregate

Fields in org.apache.flink.table.runtime.operators.aggregate declared as RecordCounter

Modifier and Type	Field	Description
protected RecordCounter	GroupAggFunctionBase.recordCounter	Used to count the number of added and retracted input records.

Methods in org.apache.flink.table.runtime.operators.aggregate that return RecordCounter

Modifier and Type	Method	Description
static RecordCounter	RecordCounter.of(int indexOfCountStar)	Creates a RecordCounter depends on the index of count(*).

Uses of RecordCounter in org.apache.flink.table.runtime.operators.aggregate.utils

Constructors in org.apache.flink.table.runtime.operators.aggregate.utils with parameters of type RecordCounter

Constructor	Description
GroupAggHelper(RecordCounter recordCounter, boolean generateUpdateBefore, org.apache.flink.api.common.state.StateTtlConfig ttlConfig, AggsHandleFunction function, RecordEqualiser equaliser)

Uses of RecordCounter in org.apache.flink.table.runtime.operators.window.groupwindow.operator

Fields in org.apache.flink.table.runtime.operators.window.groupwindow.operator declared as RecordCounter

Modifier and Type	Field	Description
protected RecordCounter	WindowOperator.recordCounter	Used to count the number of added and retracted input records.