Package | Description |
---|---|
org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream |
Class and Description |
---|
AbstractStreamArrowPythonBoundedRangeOperator
The Abstract class of Stream Arrow Python
AggregateFunction Operator for RANGE clause
bounded Over Window Aggregation. |
AbstractStreamArrowPythonBoundedRowsOperator
The Abstract class of Stream Arrow Python
AggregateFunction Operator for ROWS clause
bounded Over Window Aggregation. |
AbstractStreamArrowPythonOverWindowAggregateFunctionOperator
The Abstract class of Stream Arrow Python
AggregateFunction Operator for Over Window
Aggregation. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.