backtype.storm.serialization

Class GzipThriftSerializationDelegate

java.lang.Object

backtype.storm.serialization.GzipThriftSerializationDelegate

All Implemented Interfaces:

SerializationDelegate

public class GzipThriftSerializationDelegate
extends Object
implements SerializationDelegate

Note, this assumes it's deserializing a gzip byte stream, and will err if it encounters any other serialization.

Constructor Summary

Constructors

Constructor and Description
GzipThriftSerializationDelegate()

Method Summary

Methods

Modifier and Type	Method and Description
<T> T	deserialize(byte[] bytes, Class<T> clazz)
void	prepare(Map stormConf) Lifecycle step that will be called after instantiating with nullary constructor.
byte[]	serialize(Object object)

Methods inherited from class java.lang.Object

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

Constructor Detail

GzipThriftSerializationDelegate

public GzipThriftSerializationDelegate()

Method Detail

prepare

public void prepare(Map stormConf)

Description copied from interface: SerializationDelegate

Lifecycle step that will be called after instantiating with nullary constructor.

Specified by:

prepare in interface SerializationDelegate

serialize

public byte[] serialize(Object object)

Specified by:

serialize in interface SerializationDelegate

deserialize

public <T> T deserialize(byte[] bytes,
                Class<T> clazz)

Specified by:

deserialize in interface SerializationDelegate