Class BaseStateUpdater<S extends State>

java.lang.Object
org.apache.storm.trident.operation.BaseOperation
org.apache.storm.trident.state.BaseStateUpdater<S>
All Implemented Interfaces:
Serializable, Operation, StateUpdater<S>
Direct Known Subclasses:
AbstractRedisStateUpdater, EsUpdater, HdfsUpdater, HiveUpdater, JdbcUpdater, JmsUpdater, TridentKafkaStateUpdater

public abstract class BaseStateUpdater<S extends State> extends BaseOperation implements StateUpdater<S>
See Also:
  • Constructor Details

    • BaseStateUpdater

      public BaseStateUpdater()