Package org.apache.storm.trident.state
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 Summary
-
Method Summary
Methods inherited from class org.apache.storm.trident.operation.BaseOperation
cleanup, prepare
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.storm.trident.state.StateUpdater
updateState
-
Constructor Details
-
BaseStateUpdater
public BaseStateUpdater()
-