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

Packages that use AbstractEmbeddedDataStreamPythonFunctionOperator

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

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

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

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

Methods in org.apache.flink.streaming.api.operators.python.embedded that return AbstractEmbeddedDataStreamPythonFunctionOperator

Modifier and Type	Method	Description
<T> AbstractEmbeddedDataStreamPythonFunctionOperator<T>	EmbeddedPythonCoProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<T> outputTypeInfo)
<T> AbstractEmbeddedDataStreamPythonFunctionOperator<T>	EmbeddedPythonKeyedCoProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<T> outputTypeInfo)
<T> AbstractEmbeddedDataStreamPythonFunctionOperator<T>	EmbeddedPythonKeyedProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<T> outputTypeInfo)
<T> AbstractEmbeddedDataStreamPythonFunctionOperator<T>	EmbeddedPythonProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<T> outputTypeInfo)