Uses of Package
org.apache.flink.streaming.api.transformations.python
-
Packages that use org.apache.flink.streaming.api.transformations.python Package Description org.apache.flink.streaming.api.transformations.python org.apache.flink.streaming.runtime.translators.python -
Classes in org.apache.flink.streaming.api.transformations.python used by org.apache.flink.streaming.api.transformations.python Class Description DelegateOperatorTransformation For thoseTransformationthat don't have an operator entity,DelegateOperatorTransformationprovides aSimpleOperatorFactorycontaining aDelegateOperatorTransformation.DelegateOperator, which can hold special configurations during transformation preprocessing for Python jobs, and later be queried at translation stage. -
Classes in org.apache.flink.streaming.api.transformations.python used by org.apache.flink.streaming.runtime.translators.python Class Description PythonBroadcastStateTransformation ATransformationrepresenting a Python Co-Broadcast-Process operation, which will be translated into different operations byPythonBroadcastStateTransformationTranslator.PythonKeyedBroadcastStateTransformation ATransformationrepresenting a Python Keyed-Co-Broadcast-Process operation, which will be translated into different operations byPythonKeyedBroadcastStateTransformationTranslator.