Package org.apache.flink.streaming.api.utils

Class Summary

Class	Description
ByteArrayWrapper	A wrapper of the byte array.
ByteArrayWrapperSerializer	The serializer of ByteArrayWrapper.
ByteArrayWrapperSerializer.ByteArrayWrapperSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
ClassLeakCleaner	Utilities to clean up the leaking classes.
PythonTypeUtils	A util class for converting the given TypeInformation to other objects.
PythonTypeUtils.TypeInfoToProtoConverter	Get coder proto according to the given type information.
PythonTypeUtils.TypeInfoToSerializerConverter	Get serializers according to the given typeInformation.

Enum Summary

Enum	Description
PythonOperatorUtils	The collectors used to collect Row values.
PythonOperatorUtils.CoFlatMapFunctionOutputFlag	The Flag for PythonCoFlatMapFunction output data.
PythonOperatorUtils.CoMapFunctionOutputFlag	The Flag for PythonCoMapFunction output data.
PythonOperatorUtils.KeyedProcessFunctionInputFlag	The Flag for PythonKeyedProcessFunction input data.
PythonOperatorUtils.KeyedProcessFunctionOutputFlag	The Flag for PythonKeyedProcessFunction output data.