pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.add_default_kryo_serializer

StreamExecutionEnvironment.add_default_kryo_serializer(type_class_name: str, serializer_class_name: str)

Adds a new Kryo default serializer to the Runtime.

Example:

>>> env.add_default_kryo_serializer("com.aaa.bbb.TypeClass", "com.aaa.bbb.Serializer")

Parameters

• type_class_name – The full-qualified java class name of the types serialized with the given serializer.

• serializer_class_name – The full-qualified java class name of the serializer to use.

Note

Deprecated since version 1.19: Register data types and serializers through hard codes is deprecated, because you need to modify the codes when upgrading job version. You should configure this by option pipeline.serialization-config.