Package org.apache.storm.state
Class DefaultStateSerializer<T>
java.lang.Object
org.apache.storm.state.DefaultStateSerializer<T>
- All Implemented Interfaces:
- Serializable,- Serializer<T>
A default implementation that uses Kryo to serialize and de-serialize the state.
- See Also:
- 
Constructor SummaryConstructorsConstructorDescriptionDefaultStateSerializer(Map<String, Object> topoConf, TopologyContext context) DefaultStateSerializer(Map<String, Object> topoConf, TopologyContext context, List<Class<?>> classesToRegister) Constructs aDefaultStateSerializerinstance with the given list of classes registered in kryo.
- 
Method Summary
- 
Constructor Details- 
DefaultStateSerializerpublic DefaultStateSerializer(Map<String, Object> topoConf, TopologyContext context, List<Class<?>> classesToRegister) Constructs aDefaultStateSerializerinstance with the given list of classes registered in kryo.- Parameters:
- classesToRegister- the classes to register.
 
- 
DefaultStateSerializer
- 
DefaultStateSerializerpublic DefaultStateSerializer()
 
- 
- 
Method Details- 
serialize- Specified by:
- serializein interface- Serializer<T>
 
- 
deserialize- Specified by:
- deserializein interface- Serializer<T>
 
 
-