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 Summary
Constructors -
Method Summary
Modifier 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
-
forPath
protected static String forPath(org.apache.storm.shade.org.apache.curator.framework.api.PathAndBytesable<String> builder, String path, byte[] data) throws Exception - Throws:
Exception
-
createNode
protected 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
-
close
public void close()
-