Class DefaultStateSerializer<T>

java.lang.Object
org.apache.storm.state.DefaultStateSerializer<T>
All Implemented Interfaces:
Serializable, Serializer<T>

public class DefaultStateSerializer<T> extends Object implements Serializer<T>
A default implementation that uses Kryo to serialize and de-serialize the state.
See Also:
  • Constructor Details

    • DefaultStateSerializer

      public DefaultStateSerializer(Map<String,Object> topoConf, TopologyContext context, List<Class<?>> classesToRegister)
      Constructs a DefaultStateSerializer instance with the given list of classes registered in kryo.
      Parameters:
      classesToRegister - the classes to register.
    • DefaultStateSerializer

      public DefaultStateSerializer(Map<String,Object> topoConf, TopologyContext context)
    • DefaultStateSerializer

      public DefaultStateSerializer()
  • Method Details