backtype.storm.transactional.state

Class TransactionalState

java.lang.Object

backtype.storm.transactional.state.TransactionalState

Direct Known Subclasses:

TestTransactionalState

public class TransactionalState
extends Object

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TransactionalState(Map conf, String id, Map componentConf, String subroot)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
protected static void	createNode(org.apache.curator.framework.CuratorFramework curator, String path, byte[] data, List<org.apache.zookeeper.data.ACL> acls, org.apache.zookeeper.CreateMode mode)
void	delete(String path)
protected static String	forPath(org.apache.curator.framework.api.PathAndBytesable<String> builder, String path, byte[] data)
Object	getData(String path)
List<String>	list(String path)
void	mkdir(String path)
static TransactionalState	newCoordinatorState(Map conf, String id, Map componentConf)
static TransactionalState	newUserState(Map conf, String id, Map componentConf)
void	setData(String path, 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(Map conf,
                  String id,
                  Map componentConf,
                  String subroot)

Method Detail

newUserState

public static TransactionalState newUserState(Map conf,
                              String id,
                              Map componentConf)

newCoordinatorState

public static TransactionalState newCoordinatorState(Map conf,
                                     String id,
                                     Map componentConf)

forPath

protected static String forPath(org.apache.curator.framework.api.PathAndBytesable<String> builder,
             String path,
             byte[] data)
                         throws Exception

Throws:

Exception

createNode

protected static void createNode(org.apache.curator.framework.CuratorFramework curator,
              String path,
              byte[] data,
              List<org.apache.zookeeper.data.ACL> acls,
              org.apache.zookeeper.CreateMode mode)
                          throws Exception

Throws:

Exception

setData

public void setData(String path,
           Object obj)

delete

public void delete(String path)

list

public List<String> list(String path)

mkdir

public void mkdir(String path)

getData

public Object getData(String path)

close

public void close()