Package org.apache.flink.table.runtime.operators.aggregate

Class GroupAggFunctionBase

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.streaming.api.functions.KeyedProcessFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>

org.apache.flink.table.runtime.operators.aggregate.GroupAggFunctionBase

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction

Direct Known Subclasses:

AsyncStateGroupAggFunction, GroupAggFunction

public abstract class GroupAggFunctionBase
extends org.apache.flink.streaming.api.functions.KeyedProcessFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>

Base class for GroupAggFunction and AsyncStateGroupAggFunction.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.streaming.api.functions.KeyedProcessFunction

org.apache.flink.streaming.api.functions.KeyedProcessFunction.Context, org.apache.flink.streaming.api.functions.KeyedProcessFunction.OnTimerContext

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.flink.table.types.logical.LogicalType[]	accTypes	The accumulator types.
protected RecordEqualiser	equaliser
protected AggsHandleFunction	function
protected GeneratedAggsHandleFunction	genAggsHandler	The code generated function used to handle aggregates.
protected boolean	generateUpdateBefore	Whether this operator will generate UPDATE_BEFORE messages.
protected GeneratedRecordEqualiser	genRecordEqualiser	The code generated equaliser used to equal RowData.
protected RecordCounter	recordCounter	Used to count the number of added and retracted input records.
protected org.apache.flink.api.common.state.StateTtlConfig	ttlConfig	State idle retention config.

Constructor Summary

Constructors

Constructor	Description
GroupAggFunctionBase(GeneratedAggsHandleFunction genAggsHandler, GeneratedRecordEqualiser genRecordEqualiser, org.apache.flink.table.types.logical.LogicalType[] accTypes, int indexOfCountStar, boolean generateUpdateBefore, long stateRetentionTime)

Method Summary

Modifier and Type	Method	Description
void	close()
void	open(org.apache.flink.api.common.functions.OpenContext openContext)

Methods inherited from class org.apache.flink.streaming.api.functions.KeyedProcessFunction

onTimer, processElement

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

getIterationRuntimeContext, getRuntimeContext, setRuntimeContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

genAggsHandler

protected final GeneratedAggsHandleFunction genAggsHandler

The code generated function used to handle aggregates.

genRecordEqualiser

protected final GeneratedRecordEqualiser genRecordEqualiser

The code generated equaliser used to equal RowData.

accTypes

protected final org.apache.flink.table.types.logical.LogicalType[] accTypes

The accumulator types.

recordCounter

protected final RecordCounter recordCounter

Used to count the number of added and retracted input records.

generateUpdateBefore

protected final boolean generateUpdateBefore

Whether this operator will generate UPDATE_BEFORE messages.

ttlConfig

protected final org.apache.flink.api.common.state.StateTtlConfig ttlConfig

State idle retention config.

function

protected transient AggsHandleFunction function

equaliser

protected transient RecordEqualiser equaliser

Constructor Detail

GroupAggFunctionBase

public GroupAggFunctionBase(GeneratedAggsHandleFunction genAggsHandler,
                            GeneratedRecordEqualiser genRecordEqualiser,
                            org.apache.flink.table.types.logical.LogicalType[] accTypes,
                            int indexOfCountStar,
                            boolean generateUpdateBefore,
                            long stateRetentionTime)

Method Detail

open

public void open(org.apache.flink.api.common.functions.OpenContext openContext)
          throws Exception

Specified by:

open in interface org.apache.flink.api.common.functions.RichFunction

Overrides:

open in class org.apache.flink.api.common.functions.AbstractRichFunction

Throws:

Exception

close

public void close()
           throws Exception

Specified by:

close in interface org.apache.flink.api.common.functions.RichFunction

Overrides:

close in class org.apache.flink.api.common.functions.AbstractRichFunction

Throws:

Exception