storm.trident.topology.state
Class RotatingTransactionalState
java.lang.Object
storm.trident.topology.state.RotatingTransactionalState
public class RotatingTransactionalState
- extends java.lang.Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
RotatingTransactionalState
public RotatingTransactionalState(TransactionalState state,
java.lang.String subdir)
getLastState
public java.lang.Object getLastState()
overrideState
public void overrideState(long txid,
java.lang.Object state)
removeState
public void removeState(long txid)
getState
public java.lang.Object getState(long txid,
RotatingTransactionalState.StateInitializer init)
hasCache
public boolean hasCache(long txid)
getStateOrCreate
public java.lang.Object getStateOrCreate(long txid,
RotatingTransactionalState.StateInitializer init)
- Returns null if it was created, the value otherwise.
cleanupBefore
public void cleanupBefore(long txid)