storm.trident.topology.state
Class RotatingTransactionalState

java.lang.Object
  storm.trident.topology.state.RotatingTransactionalState

public class RotatingTransactionalState
extends java.lang.Object

Nested Class Summary

static interface

RotatingTransactionalState.StateInitializer

Constructor Summary

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

Method Summary

void	cleanupBefore(long txid)
java.lang.Object	getLastState()
java.lang.Object	getState(long txid, RotatingTransactionalState.StateInitializer init)
java.lang.Object	getStateOrCreate(long txid, RotatingTransactionalState.StateInitializer init) Returns null if it was created, the value otherwise.
boolean	hasCache(long txid)
void	overrideState(long txid, java.lang.Object state)
void	removeState(long 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)

Method Detail

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)