Package org.apache.storm.serialization
Class GzipBridgeThriftSerializationDelegate
- java.lang.Object
-
- org.apache.storm.serialization.GzipBridgeThriftSerializationDelegate
-
- All Implemented Interfaces:
SerializationDelegate
public class GzipBridgeThriftSerializationDelegate extends Object implements SerializationDelegate
Always writes gzip out, but tests incoming to see if it's gzipped. If it is, deserializes with gzip. If not, usesThriftSerializationDelegate
to deserialize. Any logic needing to be enabled viaprepare(java.util.Map)
is passed through to both delegates.
-
-
Constructor Summary
Constructors Constructor Description GzipBridgeThriftSerializationDelegate()
-
Method Summary
All Methods Instance Methods Concrete Methods 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)
-
-
-
Method Detail
-
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 interfaceSerializationDelegate
-
serialize
public byte[] serialize(Object object)
- Specified by:
serialize
in interfaceSerializationDelegate
-
deserialize
public <T> T deserialize(byte[] bytes, Class<T> clazz)
- Specified by:
deserialize
in interfaceSerializationDelegate
-
-