org.apache.samza.serializers

Class JsonSerdeV2<T>

java.lang.Object

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

Type Parameters:

T - the type of the POJO being (de)serialized.

All Implemented Interfaces:

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

public class JsonSerdeV2<T>
extends java.lang.Object
implements Serde<T>

A serializer for UTF-8 encoded JSON strings. JsonSerdeV2 differs from JsonSerde in that:

1. It allows specifying the specific POJO type to deserialize to (using JsonSerdeV2(Class<T>) or JsonSerdeV2#of(Class<T>). JsonSerde always returns a LinkedHashMap<String, Object> upon deserialization.
2. It uses Jackson's default 'camelCase' property naming convention, which simplifies defining the POJO to bind to. JsonSerde enforces the 'dash-separated' property naming convention.

This JsonSerdeV2 should be preferred over JsonSerde for High Level API applications, unless backwards compatibility with the older data format (with dasherized names) is required.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
JsonSerdeV2() Constructs a JsonSerdeV2 that returns a LinkedHashMap<String, Object< upon deserialization.
JsonSerdeV2(java.lang.Class<T> clazz) Constructs a JsonSerdeV2 that (de)serializes POJOs of class clazz.

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.
static <T> JsonSerdeV2<T>	of(java.lang.Class<T> clazz)
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

JsonSerdeV2

public JsonSerdeV2()

Constructs a JsonSerdeV2 that returns a LinkedHashMap<String, Object< upon deserialization.

JsonSerdeV2

public JsonSerdeV2(java.lang.Class<T> clazz)

Constructs a JsonSerdeV2 that (de)serializes POJOs of class clazz.

Parameters:

clazz - the class of the POJO being (de)serialized.

Method Detail

of

public static <T> JsonSerdeV2<T> of(java.lang.Class<T> clazz)

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>

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>

Parameters:

bytes - Array of bytes representing serialized object.

Returns:

Original deserialized object.