org.apache.giraph.writable.kryo.serializers

Class FastUtilSerializer<T>

java.lang.Object

com.esotericsoftware.kryo.Serializer<T>

org.apache.giraph.writable.kryo.serializers.FastUtilSerializer<T>

Type Parameters:

T - Object type

public class FastUtilSerializer<T>
extends com.esotericsoftware.kryo.Serializer<T>

Kryo Serializer for Fastutil collection class. By default, because they extend boxed collections, are being serialized very inefficiently through a lot of temporary object creation. We are relying that fastutil classes are written to be correctly serialized with Java serialization, and have put transient on all array fields and are doing custom efficient serialization in writeObject/readObject methods. This Serializer then swaps ObjectOutputStream for all default fields with FieldSerializer, and then calls appropriate writeObject/readObject methods. We are also relying on defaultWriteObject/defaultReadObject being effectively called first within those methods

Constructor Summary

Constructors

Constructor and Description
FastUtilSerializer(com.esotericsoftware.kryo.Kryo kryo, Class<T> type) Creates and initializes new serializer for a given fastutil class.

Method Summary

Modifier and Type	Method and Description
T	read(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, Class<T> type)
static void	register(com.esotericsoftware.kryo.Kryo kryo, Class<?> fastutilClass) Register serializer for a given fastutil class.
static void	registerAll(com.esotericsoftware.kryo.Kryo kryo) Registers serializers for all possible fastutil classes.
static void	registerArrayBigList(com.esotericsoftware.kryo.Kryo kryo) Register all Fastutil ArrayBigLists.
static void	registerArrayLists(com.esotericsoftware.kryo.Kryo kryo) Register all Fastutil ArrayLists.
static void	registerArraySets(com.esotericsoftware.kryo.Kryo kryo) Register all Fastutil ArraySets.
static void	registerAVLTreeMaps(com.esotericsoftware.kryo.Kryo kryo) Register all Fastutil AVLTreeMaps.
static void	registerAVLTreeSets(com.esotericsoftware.kryo.Kryo kryo) Register all Fastutil AVLTreeSets.
static void	registerOpenHashMaps(com.esotericsoftware.kryo.Kryo kryo) Register all Fastutil OpenHashMaps.
static void	registerOpenHashSets(com.esotericsoftware.kryo.Kryo kryo) Register all Fastutil OpenHashSets.
static void	registerRBTreeMaps(com.esotericsoftware.kryo.Kryo kryo) Register all Fastutil RBTreeMaps.
static void	registerRBTreeSets(com.esotericsoftware.kryo.Kryo kryo) Register all Fastutil RBTreeSets.
void	write(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output output, T object)

Methods inherited from class com.esotericsoftware.kryo.Serializer

copy, getAcceptsNull, isImmutable, setAcceptsNull, setGenerics, setImmutable

Methods inherited from class java.lang.Object

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

Constructor Detail

FastUtilSerializer

public FastUtilSerializer(com.esotericsoftware.kryo.Kryo kryo,
                          Class<T> type)

Creates and initializes new serializer for a given fastutil class.

Parameters:

kryo - Kryo instance

type - Fastutil class

Method Detail

register

public static void register(com.esotericsoftware.kryo.Kryo kryo,
                            Class<?> fastutilClass)

Register serializer for a given fastutil class.

Parameters:

kryo - Kryo instance

fastutilClass - Fastutil class

registerAll

public static void registerAll(com.esotericsoftware.kryo.Kryo kryo)

Registers serializers for all possible fastutil classes. There are many fastutil classes, so it is recommended to call this function at the end, so they fastutil classes don't use up small registration numbers.

Parameters:

kryo - Kryo instance

registerArrayLists

public static void registerArrayLists(com.esotericsoftware.kryo.Kryo kryo)

Register all Fastutil ArrayLists.

Parameters:

kryo - Kryo instance

registerArrayBigList

public static void registerArrayBigList(com.esotericsoftware.kryo.Kryo kryo)

Register all Fastutil ArrayBigLists.

Parameters:

kryo - Kryo instance

registerOpenHashSets

public static void registerOpenHashSets(com.esotericsoftware.kryo.Kryo kryo)

Register all Fastutil OpenHashSets.

Parameters:

kryo - Kryo instance

registerArraySets

public static void registerArraySets(com.esotericsoftware.kryo.Kryo kryo)

Register all Fastutil ArraySets.

Parameters:

kryo - Kryo instance

registerRBTreeSets

public static void registerRBTreeSets(com.esotericsoftware.kryo.Kryo kryo)

Register all Fastutil RBTreeSets.

Parameters:

kryo - Kryo instance

registerAVLTreeSets

public static void registerAVLTreeSets(com.esotericsoftware.kryo.Kryo kryo)

Register all Fastutil AVLTreeSets.

Parameters:

kryo - Kryo instance

registerOpenHashMaps

public static void registerOpenHashMaps(com.esotericsoftware.kryo.Kryo kryo)

Register all Fastutil OpenHashMaps.

Parameters:

kryo - Kryo instance

registerRBTreeMaps

public static void registerRBTreeMaps(com.esotericsoftware.kryo.Kryo kryo)

Register all Fastutil RBTreeMaps.

Parameters:

kryo - Kryo instance

registerAVLTreeMaps

public static void registerAVLTreeMaps(com.esotericsoftware.kryo.Kryo kryo)

Register all Fastutil AVLTreeMaps.

Parameters:

kryo - Kryo instance

write

public void write(com.esotericsoftware.kryo.Kryo kryo,
                  com.esotericsoftware.kryo.io.Output output,
                  T object)

Specified by:

write in class com.esotericsoftware.kryo.Serializer<T>

read

public T read(com.esotericsoftware.kryo.Kryo kryo,
              com.esotericsoftware.kryo.io.Input input,
              Class<T> type)

Specified by:

read in class com.esotericsoftware.kryo.Serializer<T>