org.apache.giraph.writable.kryo.serializers

Class DirectWritableSerializer<T extends org.apache.hadoop.io.Writable>

java.lang.Object

com.esotericsoftware.kryo.Serializer<T>

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

Type Parameters:

T - Object type, should implement Writable

public class DirectWritableSerializer<T extends org.apache.hadoop.io.Writable>
extends com.esotericsoftware.kryo.Serializer<T>

A custom Serializer that will call the Writable methods defined by the object itself to serialize the object, instead of Kryo auto-magically serializing

Constructor Summary

Constructors

Constructor and Description
DirectWritableSerializer()

Method Summary

Modifier and Type	Method and Description
T	copy(com.esotericsoftware.kryo.Kryo kryo, T original)
protected T	create(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, Class<T> type) Used by read(Kryo, Input, Class) to create the new object.
T	read(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, Class<T> type)
void	write(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output output, T object)

Methods inherited from class com.esotericsoftware.kryo.Serializer

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

DirectWritableSerializer

public DirectWritableSerializer()

Method Detail

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 extends org.apache.hadoop.io.Writable>

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 extends org.apache.hadoop.io.Writable>

copy

public T copy(com.esotericsoftware.kryo.Kryo kryo,
              T original)

Overrides:

copy in class com.esotericsoftware.kryo.Serializer<T extends org.apache.hadoop.io.Writable>

create

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

Used by read(Kryo, Input, Class) to create the new object. This can be overridden to customize object creation, eg to call a constructor with arguments. The default implementation uses Kryo.newInstance(Class).

Parameters:

kryo - Kryo object instance

input - Input

type - Type of the class to create

Returns:

New instance of wanted type