Package | Description |
---|---|
org.apache.flink.table.runtime.operators.python.aggregate |
Class and Description |
---|
AbstractPythonStreamAggregateOperator
Base class for
AbstractPythonStreamGroupAggregateOperator and PythonStreamGroupWindowAggregateOperator . |
AbstractPythonStreamGroupAggregateOperator
Base class for
PythonStreamGroupAggregateOperator and PythonStreamGroupTableAggregateOperator . |
PythonStreamGroupWindowAggregateOperator
The Python Group Window AggregateFunction operator.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.