pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.add_default_kryo_serializer#
- StreamExecutionEnvironment.add_default_kryo_serializer(type_class_name: str, serializer_class_name: str)[source]#
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.