Uses of Class
org.apache.flink.table.runtime.operators.python.AbstractStatelessFunctionOperator
-
-
Uses of AbstractStatelessFunctionOperator in org.apache.flink.table.runtime.operators.python.aggregate.arrow
Subclasses of AbstractStatelessFunctionOperator in org.apache.flink.table.runtime.operators.python.aggregate.arrow Modifier and Type Class Description classAbstractArrowPythonAggregateFunctionOperatorThe Abstract class of Arrow Aggregate Operator for PandasAggregateFunction. -
Uses of AbstractStatelessFunctionOperator in org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch
Subclasses of AbstractStatelessFunctionOperator in org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch Modifier and Type Class Description classBatchArrowPythonGroupAggregateFunctionOperatorThe Batch Arrow PythonAggregateFunctionOperator for Group Aggregation.classBatchArrowPythonGroupWindowAggregateFunctionOperatorThe Batch Arrow PythonAggregateFunctionOperator for Group Window Aggregation.classBatchArrowPythonOverWindowAggregateFunctionOperatorThe Batch Arrow PythonAggregateFunctionOperator for Over Window Aggregation. -
Uses of AbstractStatelessFunctionOperator in org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream
Subclasses of AbstractStatelessFunctionOperator in org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream Modifier and Type Class Description classAbstractStreamArrowPythonBoundedRangeOperator<K>The Abstract class of Stream Arrow PythonAggregateFunctionOperator for RANGE clause bounded Over Window Aggregation.classAbstractStreamArrowPythonBoundedRowsOperator<K>The Abstract class of Stream Arrow PythonAggregateFunctionOperator for ROWS clause bounded Over Window Aggregation.classAbstractStreamArrowPythonOverWindowAggregateFunctionOperator<K>The Abstract class of Stream Arrow PythonAggregateFunctionOperator for Over Window Aggregation.classStreamArrowPythonGroupWindowAggregateFunctionOperator<K,W extends org.apache.flink.table.runtime.operators.window.Window>The Stream Arrow PythonAggregateFunctionOperator for Group Window Aggregation.classStreamArrowPythonProcTimeBoundedRangeOperator<K>The Stream Arrow PythonAggregateFunctionOperator for ROWS clause proc-time bounded OVER window.classStreamArrowPythonProcTimeBoundedRowsOperator<K>The Stream Arrow PythonAggregateFunctionOperator for ROWS clause proc-time bounded OVER window.classStreamArrowPythonRowTimeBoundedRangeOperator<K>The Stream Arrow PythonAggregateFunctionOperator for RANGE clause event-time bounded OVER window.classStreamArrowPythonRowTimeBoundedRowsOperator<K>The Stream Arrow PythonAggregateFunctionOperator for RANGE clause event-time bounded OVER window. -
Uses of AbstractStatelessFunctionOperator in org.apache.flink.table.runtime.operators.python.scalar
Subclasses of AbstractStatelessFunctionOperator in org.apache.flink.table.runtime.operators.python.scalar Modifier and Type Class Description classAbstractPythonScalarFunctionOperatorBase class for all stream operators to execute PythonScalarFunctions.classPythonScalarFunctionOperatorThe PythonScalarFunctionoperator. -
Uses of AbstractStatelessFunctionOperator in org.apache.flink.table.runtime.operators.python.scalar.arrow
Subclasses of AbstractStatelessFunctionOperator in org.apache.flink.table.runtime.operators.python.scalar.arrow Modifier and Type Class Description classArrowPythonScalarFunctionOperatorArrow PythonScalarFunctionoperator. -
Uses of AbstractStatelessFunctionOperator in org.apache.flink.table.runtime.operators.python.table
Subclasses of AbstractStatelessFunctionOperator in org.apache.flink.table.runtime.operators.python.table Modifier and Type Class Description classPythonTableFunctionOperatorThe PythonTableFunctionoperator.
-