Package org.apache.flink.streaming.runtime.translators.python
-
Class Summary Class Description PythonBroadcastStateTransformationTranslator<IN1,IN2,OUT> ATransformationTranslatorthat translatesPythonBroadcastStateTransformationintoExternalPythonCoProcessOperator/EmbeddedPythonCoProcessOperatorin streaming mode orExternalPythonBatchCoBroadcastProcessOperator/EmbeddedPythonBatchCoBroadcastProcessOperatorin batch mode.PythonKeyedBroadcastStateTransformationTranslator<OUT> ATransformationTranslatorthat translatesPythonKeyedBroadcastStateTransformationintoExternalPythonKeyedCoProcessOperator/EmbeddedPythonKeyedCoProcessOperatorin streaming mode orExternalPythonBatchKeyedCoBroadcastProcessOperator/EmbeddedPythonBatchKeyedCoBroadcastProcessOperatorin batch mode.