Package org.apache.storm.serialization

Class GzipSerializationDelegate

java.lang.Object

org.apache.storm.serialization.GzipSerializationDelegate

All Implemented Interfaces:

SerializationDelegate

public class GzipSerializationDelegate
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	Description
GzipSerializationDelegate()

Method Summary

Modifier and Type	Method	Description
<T> T	deserialize(byte[] bytes, Class<T> clazz)
void	prepare(Map<String,Object> topoConf)	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 Details

GzipSerializationDelegate

public GzipSerializationDelegate()

Method Details

prepare

public void prepare(Map<String,Object> topoConf)

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