Class TransactionalState
java.lang.Object
org.apache.storm.trident.topology.state.TransactionalState
- Direct Known Subclasses:
- TestTransactionalState
Class that contains the logic to extract the transactional state info from zookeeper. All transactional state is kept in zookeeper. This
 class only contains references to Curator, which is used to get all info from zookeeper.
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoidclose()protected static voidcreateNode(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework curator, String path, byte[] data, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> acls, org.apache.storm.shade.org.apache.zookeeper.CreateMode mode) voidprotected static StringforPath(org.apache.storm.shade.org.apache.curator.framework.api.PathAndBytesable<String> builder, String path, byte[] data) voidstatic TransactionalStatenewCoordinatorState(Map<String, Object> conf, String id) static TransactionalStatenewUserState(Map<String, Object> conf, String id) void
- 
Constructor Details- 
TransactionalState
 
- 
- 
Method Details- 
newUserState
- 
newCoordinatorState
- 
forPathprotected static String forPath(org.apache.storm.shade.org.apache.curator.framework.api.PathAndBytesable<String> builder, String path, byte[] data) throws Exception - Throws:
- Exception
 
- 
createNodeprotected static void createNode(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework curator, String path, byte[] data, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> acls, org.apache.storm.shade.org.apache.zookeeper.CreateMode mode) throws Exception - Throws:
- Exception
 
- 
setData
- 
delete
- 
list
- 
mkdir
- 
getData
- 
closepublic void close()
 
-