Package org.apache.storm.serialization
Class ThriftSerializationDelegate
- java.lang.Object
-
- org.apache.storm.serialization.ThriftSerializationDelegate
-
- All Implemented Interfaces:
SerializationDelegate
public class ThriftSerializationDelegate extends Object implements SerializationDelegate
-
-
Constructor Summary
Constructors Constructor Description ThriftSerializationDelegate()
-
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
-
-