backtype.storm.transactional.state
Class TransactionalState

java.lang.Object
  extended by backtype.storm.transactional.state.TransactionalState

public class TransactionalState
extends java.lang.Object


Constructor Summary
protected TransactionalState(java.util.Map conf, java.lang.String id, java.util.Map componentConf, java.lang.String subroot)
           
 
Method Summary
 void close()
           
 void delete(java.lang.String path)
           
 java.lang.Object getData(java.lang.String path)
           
 java.util.List<java.lang.String> list(java.lang.String path)
           
 void mkdir(java.lang.String path)
           
static TransactionalState newCoordinatorState(java.util.Map conf, java.lang.String id, java.util.Map componentConf)
           
static TransactionalState newUserState(java.util.Map conf, java.lang.String id, java.util.Map componentConf)
           
 void setData(java.lang.String path, java.lang.Object obj)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TransactionalState

protected TransactionalState(java.util.Map conf,
                             java.lang.String id,
                             java.util.Map componentConf,
                             java.lang.String subroot)
Method Detail

newUserState

public static TransactionalState newUserState(java.util.Map conf,
                                              java.lang.String id,
                                              java.util.Map componentConf)

newCoordinatorState

public static TransactionalState newCoordinatorState(java.util.Map conf,
                                                     java.lang.String id,
                                                     java.util.Map componentConf)

setData

public void setData(java.lang.String path,
                    java.lang.Object obj)

delete

public void delete(java.lang.String path)

list

public java.util.List<java.lang.String> list(java.lang.String path)

mkdir

public void mkdir(java.lang.String path)

getData

public java.lang.Object getData(java.lang.String path)

close

public void close()