org.apache.flink.table.runtime.operators.python.scalar (Flink : Python 1.20.1-cp2 API)

Class Summary
Class	Description
AbstractPythonScalarFunctionOperator	Base class for all stream operators to execute Python `ScalarFunction`s.
EmbeddedPythonScalarFunctionOperator	The Python `ScalarFunction` operator in embedded Python environment.
PythonScalarFunctionOperator	The Python `ScalarFunction` operator.

Package org.apache.flink.table.runtime.operators.python.scalar