Uses of Class
org.apache.flink.streaming.api.operators.python.process.AbstractExternalPythonFunctionOperator

Packages that use AbstractExternalPythonFunctionOperator

Package	Description
org.apache.flink.streaming.api.operators.python.process
org.apache.flink.table.runtime.operators.python
org.apache.flink.table.runtime.operators.python.aggregate
org.apache.flink.table.runtime.operators.python.aggregate.arrow
org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch
org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream
org.apache.flink.table.runtime.operators.python.scalar
org.apache.flink.table.runtime.operators.python.scalar.arrow
org.apache.flink.table.runtime.operators.python.table

Uses of AbstractExternalPythonFunctionOperator in org.apache.flink.streaming.api.operators.python.process

Subclasses of AbstractExternalPythonFunctionOperator in org.apache.flink.streaming.api.operators.python.process

Modifier and Type	Class	Description
class	AbstractExternalDataStreamPythonFunctionOperator<OUT>	Base class for all Python DataStream operators executed in Python process.
class	AbstractExternalOneInputPythonFunctionOperator<IN,OUT>	AbstractExternalOneInputPythonFunctionOperator is responsible for launching beam runner which will start a python harness to execute user defined python function.
class	AbstractExternalTwoInputPythonFunctionOperator<IN1,IN2,OUT>	AbstractExternalTwoInputPythonFunctionOperator is responsible for launching beam runner which will start a python harness to execute two-input user defined python function.
class	ExternalPythonBatchCoBroadcastProcessOperator<IN1,IN2,OUT>	The ExternalPythonBatchCoBroadcastProcessOperator is responsible for executing the Python CoBroadcastProcess Function under BATCH mode, ExternalPythonCoProcessOperator is used under STREAMING mode.
class	ExternalPythonBatchKeyedCoBroadcastProcessOperator<OUT>	The ExternalPythonBatchKeyedCoBroadcastProcessOperator is responsible for executing the Python CoBroadcastProcess function under BATCH mode, ExternalPythonKeyedCoProcessOperator is used under STREAMING mode.
class	ExternalPythonCoProcessOperator<IN1,IN2,OUT>	The ExternalPythonCoProcessOperator is responsible for executing the Python CoProcess Function.
class	ExternalPythonKeyedCoProcessOperator<OUT>	ExternalPythonKeyedCoProcessOperator is responsible for launching beam runner which will start a python harness to execute user defined python CoProcess function.
class	ExternalPythonKeyedProcessOperator<OUT>	ExternalPythonKeyedProcessOperator is responsible for launching beam runner which will start a python harness to execute user defined python function.
class	ExternalPythonProcessOperator<IN,OUT>	ExternalPythonProcessOperator is responsible for launching beam runner which will start a python harness to execute user defined python ProcessFunction.

Uses of AbstractExternalPythonFunctionOperator in org.apache.flink.table.runtime.operators.python

Subclasses of AbstractExternalPythonFunctionOperator in org.apache.flink.table.runtime.operators.python

Modifier and Type	Class	Description
class	AbstractOneInputPythonFunctionOperator<IN,OUT>	Base class for all one input stream operators to execute Python functions.
class	AbstractStatelessFunctionOperator<IN,OUT,UDFIN>	Base class for all stream operators to execute Python Stateless Functions.

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

Subclasses of AbstractExternalPythonFunctionOperator in org.apache.flink.table.runtime.operators.python.aggregate

Modifier and Type	Class	Description
class	AbstractPythonStreamAggregateOperator	Base class for AbstractPythonStreamGroupAggregateOperator and PythonStreamGroupWindowAggregateOperator.
class	AbstractPythonStreamGroupAggregateOperator	Base class for PythonStreamGroupAggregateOperator and PythonStreamGroupTableAggregateOperator.
class	PythonStreamGroupAggregateOperator	The Python AggregateFunction operator.
class	PythonStreamGroupTableAggregateOperator	The Python TableAggregateFunction operator.
class	PythonStreamGroupWindowAggregateOperator<K,W extends org.apache.flink.table.runtime.operators.window.Window>	The Python Group Window AggregateFunction operator.

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

Subclasses of AbstractExternalPythonFunctionOperator in org.apache.flink.table.runtime.operators.python.aggregate.arrow

Modifier and Type	Class	Description
class	AbstractArrowPythonAggregateFunctionOperator	The Abstract class of Arrow Aggregate Operator for Pandas AggregateFunction.

Uses of AbstractExternalPythonFunctionOperator in org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch

Subclasses of AbstractExternalPythonFunctionOperator in org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch

Modifier and Type	Class	Description
class	BatchArrowPythonGroupAggregateFunctionOperator	The Batch Arrow Python AggregateFunction Operator for Group Aggregation.
class	BatchArrowPythonGroupWindowAggregateFunctionOperator	The Batch Arrow Python AggregateFunction Operator for Group Window Aggregation.
class	BatchArrowPythonOverWindowAggregateFunctionOperator	The Batch Arrow Python AggregateFunction Operator for Over Window Aggregation.

Uses of AbstractExternalPythonFunctionOperator in org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream

Subclasses of AbstractExternalPythonFunctionOperator in org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream

Modifier and Type	Class	Description
class	AbstractStreamArrowPythonBoundedRangeOperator<K>	The Abstract class of Stream Arrow Python AggregateFunction Operator for RANGE clause bounded Over Window Aggregation.
class	AbstractStreamArrowPythonBoundedRowsOperator<K>	The Abstract class of Stream Arrow Python AggregateFunction Operator for ROWS clause bounded Over Window Aggregation.
class	AbstractStreamArrowPythonOverWindowAggregateFunctionOperator<K>	The Abstract class of Stream Arrow Python AggregateFunction Operator for Over Window Aggregation.
class	StreamArrowPythonGroupWindowAggregateFunctionOperator<K,W extends org.apache.flink.table.runtime.operators.window.Window>	The Stream Arrow Python AggregateFunction Operator for Group Window Aggregation.
class	StreamArrowPythonProcTimeBoundedRangeOperator<K>	The Stream Arrow Python AggregateFunction Operator for ROWS clause proc-time bounded OVER window.
class	StreamArrowPythonProcTimeBoundedRowsOperator<K>	The Stream Arrow Python AggregateFunction Operator for ROWS clause proc-time bounded OVER window.
class	StreamArrowPythonRowTimeBoundedRangeOperator<K>	The Stream Arrow Python AggregateFunction Operator for RANGE clause event-time bounded OVER window.
class	StreamArrowPythonRowTimeBoundedRowsOperator<K>	The Stream Arrow Python AggregateFunction Operator for RANGE clause event-time bounded OVER window.

Uses of AbstractExternalPythonFunctionOperator in org.apache.flink.table.runtime.operators.python.scalar

Subclasses of AbstractExternalPythonFunctionOperator in org.apache.flink.table.runtime.operators.python.scalar

Modifier and Type	Class	Description
class	AbstractPythonScalarFunctionOperator	Base class for all stream operators to execute Python ScalarFunctions.
class	PythonScalarFunctionOperator	The Python ScalarFunction operator.

Uses of AbstractExternalPythonFunctionOperator in org.apache.flink.table.runtime.operators.python.scalar.arrow

Subclasses of AbstractExternalPythonFunctionOperator in org.apache.flink.table.runtime.operators.python.scalar.arrow

Modifier and Type	Class	Description
class	ArrowPythonScalarFunctionOperator	Arrow Python ScalarFunction operator.

Uses of AbstractExternalPythonFunctionOperator in org.apache.flink.table.runtime.operators.python.table

Subclasses of AbstractExternalPythonFunctionOperator in org.apache.flink.table.runtime.operators.python.table

Modifier and Type	Class	Description
class	PythonTableFunctionOperator	The Python TableFunction operator.