Uses of Package
org.apache.flink.streaming.api.operators.python.embedded

Packages that use org.apache.flink.streaming.api.operators.python.embedded

Package	Description
org.apache.flink.streaming.api.operators.python.embedded
org.apache.flink.table.runtime.operators.python
org.apache.flink.table.runtime.operators.python.scalar
org.apache.flink.table.runtime.operators.python.table

Classes in org.apache.flink.streaming.api.operators.python.embedded used by org.apache.flink.streaming.api.operators.python.embedded

Class and Description
AbstractEmbeddedDataStreamPythonFunctionOperator Base class for all Python DataStream operators executed in embedded Python environment.
AbstractEmbeddedPythonFunctionOperator Abstract class for all stream operators to execute Python functions in embedded Python environment.
AbstractOneInputEmbeddedPythonFunctionOperator AbstractOneInputEmbeddedPythonFunctionOperator is responsible for run Python DataStream operators with one input in Embedded Python environment.
AbstractTwoInputEmbeddedPythonFunctionOperator AbstractTwoInputEmbeddedPythonFunctionOperator is responsible for run Python DataStream operators with two input user defined python function in Embedded Python environment.
EmbeddedPythonCoProcessOperator EmbeddedPythonCoProcessOperator is responsible for executing Python CoProcessFunction in embedded Python environment.
EmbeddedPythonKeyedCoProcessOperator EmbeddedPythonKeyedCoProcessOperator is responsible for executing user defined python KeyedCoProcessFunction in embedded Python environment.

Classes in org.apache.flink.streaming.api.operators.python.embedded used by org.apache.flink.table.runtime.operators.python

Class and Description
AbstractEmbeddedPythonFunctionOperator Abstract class for all stream operators to execute Python functions in embedded Python environment.

Classes in org.apache.flink.streaming.api.operators.python.embedded used by org.apache.flink.table.runtime.operators.python.scalar

Class and Description
AbstractEmbeddedPythonFunctionOperator Abstract class for all stream operators to execute Python functions in embedded Python environment.

Classes in org.apache.flink.streaming.api.operators.python.embedded used by org.apache.flink.table.runtime.operators.python.table

Class and Description
AbstractEmbeddedPythonFunctionOperator Abstract class for all stream operators to execute Python functions in embedded Python environment.