Class TransactionalState
- java.lang.Object
-
- org.apache.storm.trident.topology.state.TransactionalState
-
- Direct Known Subclasses:
TestTransactionalState
public class TransactionalState extends Object
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.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()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)voiddelete(String path)protected static StringforPath(org.apache.storm.shade.org.apache.curator.framework.api.PathAndBytesable<String> builder, String path, byte[] data)ObjectgetData(String path)List<String>list(String path)voidmkdir(String path)static TransactionalStatenewCoordinatorState(Map<String,Object> conf, String id)static TransactionalStatenewUserState(Map<String,Object> conf, String id)voidsetData(String path, Object obj)
-
-
-
Method Detail
-
newUserState
public static TransactionalState newUserState(Map<String,Object> conf, String id)
-
newCoordinatorState
public static TransactionalState newCoordinatorState(Map<String,Object> conf, String id)
-
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
-
delete
public void delete(String path)
-
mkdir
public void mkdir(String path)
-
close
public void close()
-
-