public class ZookeeperStateStore extends Object implements IStateStore
Constructor and Description |
---|
ZookeeperStateStore(String zookeeperConnectionString) |
ZookeeperStateStore(String connectionString,
int retries,
int retryInterval) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
open() |
String |
readData(String statePath) |
void |
saveData(String statePath,
String data) |
public ZookeeperStateStore(String zookeeperConnectionString)
public ZookeeperStateStore(String connectionString, int retries, int retryInterval)
public void open()
open
in interface IStateStore
public void close()
close
in interface IStateStore
public void saveData(String statePath, String data)
saveData
in interface IStateStore
public String readData(String statePath)
readData
in interface IStateStore
Copyright © 2022 The Apache Software Foundation. All rights reserved.