pegasus.mapreduce.common.utils

Class ZookeeperUtils

java.lang.Object

pegasus.mapreduce.common.utils.ZookeeperUtils

public class ZookeeperUtils
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ZookeeperUtils()

Method Summary

Modifier and Type	Method and Description
static void	createEphemeralNode(org.apache.zookeeper.ZooKeeper zk, java.lang.String path)
static void	createOrUpdatePersistentNode(org.apache.zookeeper.ZooKeeper zk, java.lang.String path, java.lang.String value)
static void	createPersistentNode(org.apache.zookeeper.ZooKeeper zk, java.lang.String path)
static void	delete(org.apache.zookeeper.ZooKeeper zk, java.lang.String path)
static boolean	exists(org.apache.zookeeper.ZooKeeper zk, java.lang.String path)
static java.util.List<java.lang.String>	getChildren(org.apache.zookeeper.ZooKeeper zk, java.lang.String path)
static java.lang.String	getNodeData(org.apache.zookeeper.ZooKeeper zk, java.lang.String path)

Methods inherited from class java.lang.Object

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

Constructor Detail

ZookeeperUtils

public ZookeeperUtils()

Method Detail

createPersistentNode

public static void createPersistentNode(org.apache.zookeeper.ZooKeeper zk,
                                        java.lang.String path)

createOrUpdatePersistentNode

public static void createOrUpdatePersistentNode(org.apache.zookeeper.ZooKeeper zk,
                                                java.lang.String path,
                                                java.lang.String value)

getNodeData

public static java.lang.String getNodeData(org.apache.zookeeper.ZooKeeper zk,
                                           java.lang.String path)

createEphemeralNode

public static void createEphemeralNode(org.apache.zookeeper.ZooKeeper zk,
                                       java.lang.String path)

exists

public static boolean exists(org.apache.zookeeper.ZooKeeper zk,
                             java.lang.String path)

getChildren

public static java.util.List<java.lang.String> getChildren(org.apache.zookeeper.ZooKeeper zk,
                                                           java.lang.String path)

delete

public static void delete(org.apache.zookeeper.ZooKeeper zk,
                          java.lang.String path)