org.apache.samza.serializers

Class SerializableSerde<T extends java.io.Serializable>

java.lang.Object

org.apache.samza.serializers.SerializableSerde<T>

All Implemented Interfaces:

java.io.Serializable, Deserializer<T>, Serde<T>, Serializer<T>

public class SerializableSerde<T extends java.io.Serializable>
extends java.lang.Object
implements Serde<T>

A serializer for Serializable objects

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SerializableSerde()

Method Summary

Modifier and Type	Method and Description
T	fromBytes(byte[] bytes) Deserializes given serialized object from an array of bytes to its original form.
byte[]	toBytes(T obj) Serializes given object to an array of bytes.

Methods inherited from class java.lang.Object

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

Constructor Detail

SerializableSerde

public SerializableSerde()

Method Detail

toBytes

public byte[] toBytes(T obj)

Description copied from interface: Serializer

Serializes given object to an array of bytes.

Specified by:

toBytes in interface Serializer<T extends java.io.Serializable>

Parameters:

obj - Object of specific type to serialize.

Returns:

An array of bytes representing the object in serialized form.

fromBytes

public T fromBytes(byte[] bytes)

Description copied from interface: Deserializer

Deserializes given serialized object from an array of bytes to its original form.

Specified by:

fromBytes in interface Deserializer<T extends java.io.Serializable>

Parameters:

bytes - Array of bytes representing serialized object.

Returns:

Original deserialized object.