pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.register_type_with_kryo_serializer

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

Registers the given Serializer via its class as a serializer for the given type at the KryoSerializer.

Example:

>>> env.register_type_with_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.