org.corfudb.util.serializer

Interface ISerializer

All Known Implementing Classes:

CorfuSerializer, JavaSerializer, JsonSerializer, PrimitiveSerializer

public interface ISerializer

This class represents a serializer, which takes an object and reads/writes it to a bytebuf. Created by mwei on 9/17/15.

Field Summary

Fields

Modifier and Type	Field and Description
static Map<Class<?>,Function<?,byte[]>>	customHashingMap
static Map<Class<?>,Function<?,byte[]>>	hashConversionMap This map provides some methods for performing hashing on known types.
static ThreadLocal<com.esotericsoftware.kryo.Kryo>	kryos

Method Summary

Modifier and Type	Method and Description
default Object	clone(Object o, CorfuRuntime rt) Clone an object through serialization.
Object	deserialize(io.netty.buffer.ByteBuf b, CorfuRuntime rt) Deserialize an object from a given byte buffer.
default <T> Function<T,byte[]>	getCustomHasher(Class<T> cls) Get a custom hasher from the serializer.
byte	getType()
default byte[]	hash(Object o) Given an object, generate a hash for it.
default <T> void	registerCustomHasher(Class<T> cls, Function<T,byte[]> hashFunction) Register a new custom hasher with the serializer.
void	serialize(Object o, io.netty.buffer.ByteBuf b) Serialize an object into a given byte buffer.

Field Detail

kryos

static final ThreadLocal<com.esotericsoftware.kryo.Kryo> kryos

customHashingMap

static final Map<Class<?>,Function<?,byte[]>> customHashingMap

hashConversionMap

static final Map<Class<?>,Function<?,byte[]>> hashConversionMap

This map provides some methods for performing hashing on known types.

Method Detail

getType

byte getType()

deserialize

Object deserialize(io.netty.buffer.ByteBuf b,
                   CorfuRuntime rt)

Deserialize an object from a given byte buffer.

Parameters:

b - The bytebuf to deserialize.

Returns:

The deserialized object.

serialize

void serialize(Object o,
               io.netty.buffer.ByteBuf b)

Serialize an object into a given byte buffer.

Parameters:

o - The object to serialize.

b - The bytebuf to serialize it into.

registerCustomHasher

default <T> void registerCustomHasher(Class<T> cls,
                                      Function<T,byte[]> hashFunction)

Register a new custom hasher with the serializer.

Parameters:

cls - The class this hasher will handle.

hashFunction - The function to execute to generate the hash.

getCustomHasher

default <T> Function<T,byte[]> getCustomHasher(Class<T> cls)

Get a custom hasher from the serializer.

Parameters:

cls - The class to obtain a hasher for.

Returns:

A function to generate a hash, or null, if no custom hasher was registered.

hash

default byte[] hash(Object o)

Given an object, generate a hash for it. This hash is used internally by Corfu for conflict resolution. The default implementation uses xxHash, a fast non-cryptographic hash algorithm on the serialized payload. It tries to be smart about some primitive types, not serializing them if possible to generate the hashcode.

Parameters:

o - The object to hash.

Returns:

The hashed object value, as a byte array.

clone

default Object clone(Object o,
                     CorfuRuntime rt)

Clone an object through serialization.

Parameters:

o - The object to clone.

Returns:

The cloned object.