org.apache.storm.zookeeper

Class Zookeeper

java.lang.Object

org.apache.storm.zookeeper.Zookeeper

public class Zookeeper
extends Object

Constructor Summary

Constructors

Constructor and Description
Zookeeper()

Method Summary

Modifier and Type	Method and Description
static void	addListener(org.apache.curator.framework.CuratorFramework zk, org.apache.curator.framework.state.ConnectionStateListener listener)
static String	createNode(org.apache.curator.framework.CuratorFramework zk, String path, byte[] data, org.apache.zookeeper.CreateMode mode, List<org.apache.zookeeper.data.ACL> acls)
static String	createNode(org.apache.curator.framework.CuratorFramework zk, String path, byte[] data, List<org.apache.zookeeper.data.ACL> acls)
static void	deleteNode(org.apache.curator.framework.CuratorFramework zk, String path)
static void	deleteNodeBlobstore(org.apache.curator.framework.CuratorFramework zk, String parentPath, String hostPortInfo)
static boolean	exists(org.apache.curator.framework.CuratorFramework zk, String path, boolean watch)
static boolean	existsNode(org.apache.curator.framework.CuratorFramework zk, String path, boolean watch)
static List<String>	getChildren(org.apache.curator.framework.CuratorFramework zk, String path, boolean watch)
static byte[]	getData(org.apache.curator.framework.CuratorFramework zk, String path, boolean watch)
static VersionedData<byte[]>	getDataWithVersion(org.apache.curator.framework.CuratorFramework zk, String path, boolean watch) Get the data along with a version
static Integer	getVersion(org.apache.curator.framework.CuratorFramework zk, String path, boolean watch)
static org.apache.curator.framework.recipes.leader.LeaderLatchListener	leaderLatchListenerImpl(Map conf, org.apache.curator.framework.CuratorFramework zk, BlobStore blobStore, org.apache.curator.framework.recipes.leader.LeaderLatch leaderLatch)
static org.apache.curator.framework.CuratorFramework	mkClient(Map conf, List<String> servers, Object port, String root, WatcherCallBack watcher, Map authConf, List<org.apache.zookeeper.data.ACL> defaultAcl)
org.apache.curator.framework.CuratorFramework	mkClientImpl(Map conf, List<String> servers, Object port, Map authConf, List<org.apache.zookeeper.data.ACL> defaultAcl)
org.apache.curator.framework.CuratorFramework	mkClientImpl(Map conf, List<String> servers, Object port, String root, List<org.apache.zookeeper.data.ACL> defaultAcl)
org.apache.curator.framework.CuratorFramework	mkClientImpl(Map conf, List<String> servers, Object port, String root, Map authConf, List<org.apache.zookeeper.data.ACL> defaultAcl)
org.apache.curator.framework.CuratorFramework	mkClientImpl(Map conf, List<String> servers, Object port, String root, WatcherCallBack watcher, List<org.apache.zookeeper.data.ACL> defaultAcl) connect ZK, register Watch/unhandle Watch
org.apache.curator.framework.CuratorFramework	mkClientImpl(Map conf, List<String> servers, Object port, String root, WatcherCallBack watcher, Map authConf, List<org.apache.zookeeper.data.ACL> defaultAcl)
static void	mkdirs(org.apache.curator.framework.CuratorFramework zk, String path, List<org.apache.zookeeper.data.ACL> acls)
void	mkdirsImpl(org.apache.curator.framework.CuratorFramework zk, String path, List<org.apache.zookeeper.data.ACL> acls)
static List	mkInprocessZookeeper(String localdir, Integer port)
static String	normalizePath(String path)
static String	parentPath(String path)
static void	resetInstance() Resets the singleton instance to the default.
static org.apache.zookeeper.data.Stat	setData(org.apache.curator.framework.CuratorFramework zk, String path, byte[] data)
static void	setInstance(Zookeeper u) Provide an instance of this class for delegates to use.
static void	shutdownInprocessZookeeper(org.apache.zookeeper.server.NIOServerCnxnFactory handle)
static void	syncPath(org.apache.curator.framework.CuratorFramework zk, String path)
static List<String>	tokenizePath(String path)
static String	toksToPath(List<String> toks)
static NimbusInfo	toNimbusInfo(org.apache.curator.framework.recipes.leader.Participant participant)
static ILeaderElector	zkLeaderElector(Map conf, org.apache.curator.framework.CuratorFramework zkClient, BlobStore blobStore) Get master leader elector.
protected ILeaderElector	zkLeaderElectorImpl(Map conf, org.apache.curator.framework.CuratorFramework zk, BlobStore blobStore)

Methods inherited from class java.lang.Object

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

Constructor Detail

Zookeeper

public Zookeeper()

Method Detail

setInstance

public static void setInstance(Zookeeper u)

Provide an instance of this class for delegates to use. To mock out delegated methods, provide an instance of a subclass that overrides the implementation of the delegated method.

Parameters:

u - a Zookeeper instance

resetInstance

public static void resetInstance()

Resets the singleton instance to the default. This is helpful to reset the class to its original functionality when mocking is no longer desired.

mkClientImpl

public org.apache.curator.framework.CuratorFramework mkClientImpl(Map conf,
                                                                  List<String> servers,
                                                                  Object port,
                                                                  String root,
                                                                  List<org.apache.zookeeper.data.ACL> defaultAcl)

mkClientImpl

public org.apache.curator.framework.CuratorFramework mkClientImpl(Map conf,
                                                                  List<String> servers,
                                                                  Object port,
                                                                  Map authConf,
                                                                  List<org.apache.zookeeper.data.ACL> defaultAcl)

mkClientImpl

public org.apache.curator.framework.CuratorFramework mkClientImpl(Map conf,
                                                                  List<String> servers,
                                                                  Object port,
                                                                  String root,
                                                                  Map authConf,
                                                                  List<org.apache.zookeeper.data.ACL> defaultAcl)

mkClient

public static org.apache.curator.framework.CuratorFramework mkClient(Map conf,
                                                                     List<String> servers,
                                                                     Object port,
                                                                     String root,
                                                                     WatcherCallBack watcher,
                                                                     Map authConf,
                                                                     List<org.apache.zookeeper.data.ACL> defaultAcl)

mkClientImpl

public org.apache.curator.framework.CuratorFramework mkClientImpl(Map conf,
                                                                  List<String> servers,
                                                                  Object port,
                                                                  String root,
                                                                  WatcherCallBack watcher,
                                                                  Map authConf,
                                                                  List<org.apache.zookeeper.data.ACL> defaultAcl)

mkClientImpl

public org.apache.curator.framework.CuratorFramework mkClientImpl(Map conf,
                                                                  List<String> servers,
                                                                  Object port,
                                                                  String root,
                                                                  WatcherCallBack watcher,
                                                                  List<org.apache.zookeeper.data.ACL> defaultAcl)

connect ZK, register Watch/unhandle Watch

Returns:

createNode

public static String createNode(org.apache.curator.framework.CuratorFramework zk,
                                String path,
                                byte[] data,
                                org.apache.zookeeper.CreateMode mode,
                                List<org.apache.zookeeper.data.ACL> acls)

createNode

public static String createNode(org.apache.curator.framework.CuratorFramework zk,
                                String path,
                                byte[] data,
                                List<org.apache.zookeeper.data.ACL> acls)

existsNode

public static boolean existsNode(org.apache.curator.framework.CuratorFramework zk,
                                 String path,
                                 boolean watch)

deleteNode

public static void deleteNode(org.apache.curator.framework.CuratorFramework zk,
                              String path)

mkdirs

public static void mkdirs(org.apache.curator.framework.CuratorFramework zk,
                          String path,
                          List<org.apache.zookeeper.data.ACL> acls)

mkdirsImpl

public void mkdirsImpl(org.apache.curator.framework.CuratorFramework zk,
                       String path,
                       List<org.apache.zookeeper.data.ACL> acls)

syncPath

public static void syncPath(org.apache.curator.framework.CuratorFramework zk,
                            String path)

addListener

public static void addListener(org.apache.curator.framework.CuratorFramework zk,
                               org.apache.curator.framework.state.ConnectionStateListener listener)

getData

public static byte[] getData(org.apache.curator.framework.CuratorFramework zk,
                             String path,
                             boolean watch)

getVersion

public static Integer getVersion(org.apache.curator.framework.CuratorFramework zk,
                                 String path,
                                 boolean watch)
                          throws Exception

Throws:

Exception

getChildren

public static List<String> getChildren(org.apache.curator.framework.CuratorFramework zk,
                                       String path,
                                       boolean watch)

deleteNodeBlobstore

public static void deleteNodeBlobstore(org.apache.curator.framework.CuratorFramework zk,
                                       String parentPath,
                                       String hostPortInfo)

setData

public static org.apache.zookeeper.data.Stat setData(org.apache.curator.framework.CuratorFramework zk,
                                                     String path,
                                                     byte[] data)

exists

public static boolean exists(org.apache.curator.framework.CuratorFramework zk,
                             String path,
                             boolean watch)

mkInprocessZookeeper

public static List mkInprocessZookeeper(String localdir,
                                        Integer port)
                                 throws Exception

Throws:

Exception

shutdownInprocessZookeeper

public static void shutdownInprocessZookeeper(org.apache.zookeeper.server.NIOServerCnxnFactory handle)

toNimbusInfo

public static NimbusInfo toNimbusInfo(org.apache.curator.framework.recipes.leader.Participant participant)

leaderLatchListenerImpl

public static org.apache.curator.framework.recipes.leader.LeaderLatchListener leaderLatchListenerImpl(Map conf,
                                                                                                      org.apache.curator.framework.CuratorFramework zk,
                                                                                                      BlobStore blobStore,
                                                                                                      org.apache.curator.framework.recipes.leader.LeaderLatch leaderLatch)
                                                                                               throws UnknownHostException

Throws:

UnknownHostException

zkLeaderElector

public static ILeaderElector zkLeaderElector(Map conf,
                                             org.apache.curator.framework.CuratorFramework zkClient,
                                             BlobStore blobStore)
                                      throws UnknownHostException

Get master leader elector.

Parameters:

conf - Config.

zkClient - ZkClient, the client must have a default Config.STORM_ZOOKEEPER_ROOT as root path.

blobStore - BlobStore

Returns:

Instance of ILeaderElector

Throws:

UnknownHostException

zkLeaderElectorImpl

protected ILeaderElector zkLeaderElectorImpl(Map conf,
                                             org.apache.curator.framework.CuratorFramework zk,
                                             BlobStore blobStore)
                                      throws UnknownHostException

Throws:

UnknownHostException

getDataWithVersion

public static VersionedData<byte[]> getDataWithVersion(org.apache.curator.framework.CuratorFramework zk,
                                                       String path,
                                                       boolean watch)

Get the data along with a version

Parameters:

zk - the zk instance to use

path - the path to get it from

watch - should a watch be enabled

Returns:

null if no data is found, else the data with the version.

tokenizePath

public static List<String> tokenizePath(String path)

parentPath

public static String parentPath(String path)

toksToPath

public static String toksToPath(List<String> toks)

normalizePath

public static String normalizePath(String path)