Class RotatingTransactionalState
java.lang.Object
org.apache.storm.trident.topology.state.RotatingTransactionalState
-
Nested Class Summary
Nested Classes -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidcleanupBefore(long txid) getPreviousState(long txid) getState(long txid) getState(long txid, RotatingTransactionalState.StateInitializer init) getStateOrCreate(long txid, RotatingTransactionalState.StateInitializer init) Returns null if it was created, the value otherwise.booleanhasCache(long txid) voidoverrideState(long txid, Object state) voidremoveState(long txid) toString()
-
Constructor Details
-
RotatingTransactionalState
-
-
Method Details
-
getLastState
-
overrideState
-
removeState
public void removeState(long txid) -
getState
-
getState
-
getPreviousState
-
hasCache
public boolean hasCache(long txid) -
getStateOrCreate
Returns null if it was created, the value otherwise. -
cleanupBefore
public void cleanupBefore(long txid) -
toString
-