org.apache.samza.serializers

Class NoOpSerde<T>

java.lang.Object

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

Type Parameters:

T - type of messages which should not be serialized or deserialized

All Implemented Interfaces:

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

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

A marker serde class to indicate that messages should not be serialized or deserialized. This is the same behavior as when no serde is provided, and is intended for use cases where a Serde parameter or configuration is required. This is different than ByteSerde which is a pass-through serde for byte arrays.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
NoOpSerde()

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

NoOpSerde

public NoOpSerde()

Method Detail

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.

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.