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