Uses of Class
org.apache.flink.streaming.api.operators.python.embedded.AbstractTwoInputEmbeddedPythonFunctionOperator

Packages that use AbstractTwoInputEmbeddedPythonFunctionOperator

Package	Description
org.apache.flink.streaming.api.operators.python.embedded

Uses of AbstractTwoInputEmbeddedPythonFunctionOperator in org.apache.flink.streaming.api.operators.python.embedded

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

Modifier and Type	Class	Description
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.