@Internal public class Serializers extends Object
KryoSerializable
interface
to provide custom serialization for their classes.
Also, there is a Java Annotation for adding a default serializer (@DefaultSerializer) to 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 and Description |
---|
Serializers() |
Modifier and Type | Method and Description |
---|---|
static void |
recursivelyRegisterType(Class<?> type,
ExecutionConfig config,
Set<Class<?>> alreadySeen) |
static void |
recursivelyRegisterType(TypeInformation<?> typeInfo,
ExecutionConfig config,
Set<Class<?>> alreadySeen) |
public static void recursivelyRegisterType(TypeInformation<?> typeInfo, ExecutionConfig config, Set<Class<?>> alreadySeen)
public static void recursivelyRegisterType(Class<?> type, ExecutionConfig config, Set<Class<?>> alreadySeen)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.