org.apache.flink.api.java.typeutils.runtime.kryo

Class Serializers

java.lang.Object

org.apache.flink.api.java.typeutils.runtime.kryo.Serializers

@Internal
public class Serializers
extends Object

Class containing utilities for the serializers of the Flink Runtime.

Most of the serializers are automatically added to the system.

Note that users can also implement the KryoSerializable interface to provide custom serialization for their classes. Also, there is a Java Annotation for adding a default serializer (@DefaultSerializer) to classes.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Serializers.DummyAvroKryoSerializerClass<T> This is used in case we don't have Avro on the classpath.
static class	Serializers.DummyAvroRegisteredClass This is used in case we don't have Avro on the classpath.
static class	Serializers.SpecificInstanceCollectionSerializer<T extends Collection> Special serializer for Java collections enforcing certain instance types.
static class	Serializers.SpecificInstanceCollectionSerializerForArrayList Special serializer for Java's ArrayList used for Avro's GenericData.Array.

Constructor Summary

Constructors

Constructor and Description
Serializers()

Method Summary

Modifier and Type	Method and Description
static void	recursivelyRegisterType(Class<?> type, SerializerConfig config, Set<Class<?>> alreadySeen)
static void	recursivelyRegisterType(TypeInformation<?> typeInfo, SerializerConfig config, Set<Class<?>> alreadySeen)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Serializers

public Serializers()

Method Detail

recursivelyRegisterType

public static void recursivelyRegisterType(TypeInformation<?> typeInfo,
                                           SerializerConfig config,
                                           Set<Class<?>> alreadySeen)

recursivelyRegisterType

public static void recursivelyRegisterType(Class<?> type,
                                           SerializerConfig config,
                                           Set<Class<?>> alreadySeen)