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

Class Serializers.SpecificInstanceCollectionSerializer<T extends Collection>

java.lang.Object

com.esotericsoftware.kryo.Serializer<Collection>

com.esotericsoftware.kryo.serializers.CollectionSerializer

org.apache.flink.api.java.typeutils.runtime.kryo.Serializers.SpecificInstanceCollectionSerializer<T>

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

Serializers.SpecificInstanceCollectionSerializerForArrayList

Enclosing class:

Serializers

public static class Serializers.SpecificInstanceCollectionSerializer<T extends Collection>
extends com.esotericsoftware.kryo.serializers.CollectionSerializer
implements Serializable

Special serializer for Java collections enforcing certain instance types. Avro is serializing collections with an "GenericData.Array" type. Kryo is not able to handle this type, so we use ArrayLists.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class com.esotericsoftware.kryo.serializers.CollectionSerializer

com.esotericsoftware.kryo.serializers.CollectionSerializer.BindCollection

Constructor Summary

Constructors

Constructor and Description
SpecificInstanceCollectionSerializer(Class<T> type)

Method Summary

Modifier and Type	Method and Description
protected Collection	create(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, Class<Collection> type)
protected Collection	createCopy(com.esotericsoftware.kryo.Kryo kryo, Collection original)

Methods inherited from class com.esotericsoftware.kryo.serializers.CollectionSerializer

copy, read, setElementClass, setElementsCanBeNull, setGenerics, write

Methods inherited from class com.esotericsoftware.kryo.Serializer

getAcceptsNull, isImmutable, setAcceptsNull, setImmutable

Methods inherited from class java.lang.Object

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

Constructor Detail

SpecificInstanceCollectionSerializer

public SpecificInstanceCollectionSerializer(Class<T> type)

Method Detail

create

protected Collection create(com.esotericsoftware.kryo.Kryo kryo,
                            com.esotericsoftware.kryo.io.Input input,
                            Class<Collection> type)

Overrides:

create in class com.esotericsoftware.kryo.serializers.CollectionSerializer

createCopy

protected Collection createCopy(com.esotericsoftware.kryo.Kryo kryo,
                                Collection original)

Overrides:

createCopy in class com.esotericsoftware.kryo.serializers.CollectionSerializer