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)

Method Summary

void	close()
void	delete(java.lang.String path)
java.lang.Object	getData(java.lang.String path)
java.util.List<java.lang.String>	list(java.lang.String path)
void	mkdir(java.lang.String path)
static TransactionalState	newCoordinatorState(java.util.Map conf, java.lang.String id)
static TransactionalState	newUserState(java.util.Map conf, java.lang.String id)
void	setData(java.lang.String path, java.lang.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(java.util.Map conf,
                             java.lang.String id,
                             java.lang.String subroot)

Method Detail

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()