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, uses ThriftSerializationDelegate to deserialize. Any logic needing to be enabled via prepare(java.util.Map) is passed through to both delegates.