Package org.apache.storm.serialization
Class GzipBridgeThriftSerializationDelegate
java.lang.Object
org.apache.storm.serialization.GzipBridgeThriftSerializationDelegate
- All Implemented Interfaces:
SerializationDelegate
Always writes gzip out, but tests incoming to see if it's gzipped. If it is, deserializes with gzip. If not, uses
ThriftSerializationDelegate
to deserialize. Any logic needing to be enabled via prepare(java.util.Map)
is passed through to both delegates.-
Constructor Summary
-
Method Summary
-
Constructor Details
-
GzipBridgeThriftSerializationDelegate
public GzipBridgeThriftSerializationDelegate()
-
-
Method Details
-
prepare
Description copied from interface:SerializationDelegate
Lifecycle step that will be called after instantiating with nullary constructor.- Specified by:
prepare
in interfaceSerializationDelegate
-
serialize
- Specified by:
serialize
in interfaceSerializationDelegate
-
deserialize
- Specified by:
deserialize
in interfaceSerializationDelegate
-