backtype.storm.transactional.state
Class RotatingTransactionalState

java.lang.Object
  backtype.storm.transactional.state.RotatingTransactionalState

public class RotatingTransactionalState
extends java.lang.Object

A map from txid to a value. Automatically deletes txids that have been committed.

Nested Class Summary

static interface

RotatingTransactionalState.StateInitializer

Constructor Summary

RotatingTransactionalState(TransactionalState state, java.lang.String subdir)

RotatingTransactionalState(TransactionalState state, java.lang.String subdir, boolean strictOrder)

Method Summary

void	cleanupBefore(java.math.BigInteger txid)
java.lang.Object	getLastState()
java.lang.Object	getState(java.math.BigInteger txid, RotatingTransactionalState.StateInitializer init)
java.lang.Object	getStateOrCreate(java.math.BigInteger txid, RotatingTransactionalState.StateInitializer init) Returns null if it was created, the value otherwise.
void	overrideState(java.math.BigInteger txid, java.lang.Object state)
void	removeState(java.math.BigInteger txid)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RotatingTransactionalState

public RotatingTransactionalState(TransactionalState state,
                                  java.lang.String subdir,
                                  boolean strictOrder)

RotatingTransactionalState

public RotatingTransactionalState(TransactionalState state,
                                  java.lang.String subdir)

Method Detail

getLastState

public java.lang.Object getLastState()

overrideState

public void overrideState(java.math.BigInteger txid,
                          java.lang.Object state)

removeState

public void removeState(java.math.BigInteger txid)

getState

public java.lang.Object getState(java.math.BigInteger txid,
                                 RotatingTransactionalState.StateInitializer init)

getStateOrCreate

public java.lang.Object getStateOrCreate(java.math.BigInteger txid,
                                         RotatingTransactionalState.StateInitializer init)

Returns null if it was created, the value otherwise.

cleanupBefore

public void cleanupBefore(java.math.BigInteger txid)