Package org.apache.flink.streaming.api.transformations.python

Interface Summary

Interface	Description
DelegateOperatorTransformation<OUT>	For those Transformation that don't have an operator entity, DelegateOperatorTransformation provides a SimpleOperatorFactory containing a DelegateOperatorTransformation.DelegateOperator , which can hold special configurations during transformation preprocessing for Python jobs, and later be queried at translation stage.

Class Summary

Class	Description
DelegateOperatorTransformation.DelegateOperator<OUT>	DelegateOperatorTransformation.DelegateOperator holds configurations, e.g.
PythonBroadcastStateTransformation<IN1,IN2,OUT>	A Transformation representing a Python Co-Broadcast-Process operation, which will be translated into different operations by PythonBroadcastStateTransformationTranslator.
PythonKeyedBroadcastStateTransformation<OUT>	A Transformation representing a Python Keyed-Co-Broadcast-Process operation, which will be translated into different operations by PythonKeyedBroadcastStateTransformationTranslator.