org.apache.storm.eventhubs.spout

Class ZookeeperStateStore

java.lang.Object

org.apache.storm.eventhubs.spout.ZookeeperStateStore

All Implemented Interfaces:

Serializable, IStateStore

public class ZookeeperStateStore
extends Object
implements IStateStore

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ZookeeperStateStore(String zookeeperConnectionString)
ZookeeperStateStore(String connectionString, int retries, int retryInterval)

Method Summary

Modifier and Type	Method and Description
void	close()
void	open()
String	readData(String statePath)
void	saveData(String statePath, String data)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ZookeeperStateStore

public ZookeeperStateStore(String zookeeperConnectionString)

ZookeeperStateStore

public ZookeeperStateStore(String connectionString,
                           int retries,
                           int retryInterval)

Method Detail

open

public void open()

Specified by:

open in interface IStateStore

close

public void close()

Specified by:

close in interface IStateStore

saveData

public void saveData(String statePath,
                     String data)

Specified by:

saveData in interface IStateStore

readData

public String readData(String statePath)

Specified by:

readData in interface IStateStore