Uses of Class
org.apache.flink.streaming.api.operators.python.AbstractPythonFunctionOperator

Packages that use AbstractPythonFunctionOperator

Package	Description
org.apache.flink.streaming.api.operators.python.embedded
org.apache.flink.streaming.api.operators.python.process
org.apache.flink.streaming.api.transformations.python
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 AbstractPythonFunctionOperator in org.apache.flink.streaming.api.operators.python.embedded

Subclasses of AbstractPythonFunctionOperator in org.apache.flink.streaming.api.operators.python.embedded

Modifier and Type	Class	Description
class	AbstractEmbeddedDataStreamPythonFunctionOperator<OUT>	Base class for all Python DataStream operators executed in embedded Python environment.
class	AbstractEmbeddedPythonFunctionOperator<OUT>	Abstract class for all stream operators to execute Python functions in embedded Python environment.
class	AbstractOneInputEmbeddedPythonFunctionOperator<IN,OUT>	AbstractOneInputEmbeddedPythonFunctionOperator is responsible for run Python DataStream operators with one input in Embedded Python environment.
class	AbstractTwoInputEmbeddedPythonFunctionOperator<IN1,IN2,OUT>	AbstractTwoInputEmbeddedPythonFunctionOperator is responsible for run Python DataStream operators with two input user defined python function in Embedded Python environment.
class	EmbeddedPythonBatchCoBroadcastProcessOperator<IN1,IN2,OUT>	The EmbeddedPythonBatchCoBroadcastProcessOperator is responsible for executing the Python CoBroadcastProcess Function under BATCH mode, EmbeddedPythonCoProcessOperator is used under STREAMING mode.
class	EmbeddedPythonBatchKeyedCoBroadcastProcessOperator<K,IN1,IN2,OUT>	The EmbeddedPythonBatchKeyedCoBroadcastProcessOperator is responsible for executing the Python CoBroadcastProcess function under BATCH mode, EmbeddedPythonKeyedCoProcessOperator is used under STREAMING mode.
class	EmbeddedPythonCoProcessOperator<IN1,IN2,OUT>	EmbeddedPythonCoProcessOperator is responsible for executing Python CoProcessFunction in embedded Python environment.
class	EmbeddedPythonKeyedCoProcessOperator<K,IN1,IN2,OUT>	EmbeddedPythonKeyedCoProcessOperator is responsible for executing user defined python KeyedCoProcessFunction in embedded Python environment.
class	EmbeddedPythonKeyedProcessOperator<K,IN,OUT>	EmbeddedPythonKeyedProcessOperator is responsible for executing user defined python KeyedProcessFunction in embedded Python environment.
class	EmbeddedPythonProcessOperator<IN,OUT>	EmbeddedPythonProcessOperator is responsible for executing Python ProcessFunction in embedded Python environment.
class	EmbeddedPythonWindowOperator<K,IN,OUT,W extends org.apache.flink.table.runtime.operators.window.Window>	EmbeddedPythonWindowOperator is responsible for executing user defined python ProcessWindowFunction in embedded Python environment.

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

Subclasses of AbstractPythonFunctionOperator 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	AbstractExternalPythonFunctionOperator<OUT>	Abstract class for all stream operators to execute Python functions in external environment.
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 AbstractPythonFunctionOperator in org.apache.flink.streaming.api.transformations.python

Subclasses of AbstractPythonFunctionOperator in org.apache.flink.streaming.api.transformations.python

Modifier and Type	Class	Description
static class	DelegateOperatorTransformation.DelegateOperator<OUT>	DelegateOperatorTransformation.DelegateOperator holds configurations, e.g.

Methods in org.apache.flink.streaming.api.transformations.python with parameters of type AbstractPythonFunctionOperator

Modifier and Type	Method	Description
static void	DelegateOperatorTransformation.configureOperator(DelegateOperatorTransformation<?> transformation, AbstractPythonFunctionOperator<?> operator)

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

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

Modifier and Type	Class	Description
class	AbstractEmbeddedStatelessFunctionOperator	Base class for all stream operators to execute Python Stateless Functions in embedded Python environment.
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 AbstractPythonFunctionOperator in org.apache.flink.table.runtime.operators.python.aggregate

Subclasses of AbstractPythonFunctionOperator 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 AbstractPythonFunctionOperator in org.apache.flink.table.runtime.operators.python.aggregate.arrow

Subclasses of AbstractPythonFunctionOperator 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 AbstractPythonFunctionOperator in org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch

Subclasses of AbstractPythonFunctionOperator 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 AbstractPythonFunctionOperator in org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream

Subclasses of AbstractPythonFunctionOperator 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 AbstractPythonFunctionOperator in org.apache.flink.table.runtime.operators.python.scalar

Subclasses of AbstractPythonFunctionOperator 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	EmbeddedPythonScalarFunctionOperator	The Python ScalarFunction operator in embedded Python environment.
class	PythonScalarFunctionOperator	The Python ScalarFunction operator.

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

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

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

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

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

Modifier and Type	Class	Description
class	EmbeddedPythonTableFunctionOperator	The Python TableFunction operator in embedded Python environment.
class	PythonTableFunctionOperator	The Python TableFunction operator.