storm.trident.topology.state
Class TransactionalState
java.lang.Object
storm.trident.topology.state.TransactionalState
public class TransactionalState
- extends java.lang.Object
Constructor Summary |
protected |
TransactionalState(java.util.Map conf,
java.lang.String id,
java.lang.String subroot)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TransactionalState
protected TransactionalState(java.util.Map conf,
java.lang.String id,
java.lang.String subroot)
newUserState
public static TransactionalState newUserState(java.util.Map conf,
java.lang.String id)
newCoordinatorState
public static TransactionalState newCoordinatorState(java.util.Map conf,
java.lang.String id)
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()