Uses of Class
org.apache.flink.streaming.api.operators.python.embedded.EmbeddedPythonCoProcessOperator
-
Packages that use EmbeddedPythonCoProcessOperator Package Description org.apache.flink.streaming.api.operators.python.embedded -
-
Uses of EmbeddedPythonCoProcessOperator in org.apache.flink.streaming.api.operators.python.embedded
Subclasses of EmbeddedPythonCoProcessOperator in org.apache.flink.streaming.api.operators.python.embedded Modifier and Type Class Description class
EmbeddedPythonBatchCoBroadcastProcessOperator<IN1,IN2,OUT>
TheEmbeddedPythonBatchCoBroadcastProcessOperator
is responsible for executing the Python CoBroadcastProcess Function under BATCH mode,EmbeddedPythonCoProcessOperator
is used under STREAMING mode.
-