Uses of Class
org.apache.flink.table.runtime.operators.python.aggregate.PythonStreamGroupWindowAggregateOperator

Packages that use PythonStreamGroupWindowAggregateOperator

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

Uses of PythonStreamGroupWindowAggregateOperator in org.apache.flink.table.runtime.operators.python.aggregate

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

Modifier and Type	Method and Description
static <K,W extends Window> PythonStreamGroupWindowAggregateOperator<K,W>	PythonStreamGroupWindowAggregateOperator.createSessionGroupWindowAggregateOperator(Configuration config, RowType inputType, RowType outputType, PythonAggregateFunctionInfo[] aggregateFunctions, DataViewSpec[][] dataViewSpecs, int[] grouping, int indexOfCountStar, boolean generateUpdateBefore, boolean countStarInserted, int inputTimeFieldIndex, WindowAssigner<W> windowAssigner, boolean isRowTime, long gap, long allowedLateness, NamedWindowProperty[] namedProperties, ZoneId shiftTimeZone)
static <K,W extends Window> PythonStreamGroupWindowAggregateOperator<K,W>	PythonStreamGroupWindowAggregateOperator.createSlidingGroupWindowAggregateOperator(Configuration config, RowType inputType, RowType outputType, PythonAggregateFunctionInfo[] aggregateFunctions, DataViewSpec[][] dataViewSpecs, int[] grouping, int indexOfCountStar, boolean generateUpdateBefore, boolean countStarInserted, int inputTimeFieldIndex, WindowAssigner<W> windowAssigner, boolean isRowTime, boolean isTimeWindow, long size, long slide, long allowedLateness, NamedWindowProperty[] namedProperties, ZoneId shiftTimeZone)
static <K,W extends Window> PythonStreamGroupWindowAggregateOperator<K,W>	PythonStreamGroupWindowAggregateOperator.createTumblingGroupWindowAggregateOperator(Configuration config, RowType inputType, RowType outputType, PythonAggregateFunctionInfo[] aggregateFunctions, DataViewSpec[][] dataViewSpecs, int[] grouping, int indexOfCountStar, boolean generateUpdateBefore, boolean countStarInserted, int inputTimeFieldIndex, WindowAssigner<W> windowAssigner, boolean isRowTime, boolean isTimeWindow, long size, long allowedLateness, NamedWindowProperty[] namedProperties, ZoneId shiftTimeZone)