本文整理了Java中org.apache.hadoop.hbase.zookeeper.ZKAssign.getNodeName()方法的一些代码示例，展示了ZKAssign.getNodeName()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZKAssign.getNodeName()方法的具体详情如下：
包路径：org.apache.hadoop.hbase.zookeeper.ZKAssign
类名称：ZKAssign
方法名：getNodeName

ZKAssign.getNodeName介绍

[英]Gets the full path node name for the unassigned node for the specified region.
[中]获取指定区域的未分配节点的完整路径节点名。

代码示例

代码示例来源：origin: harbby/presto-connectors

/**
 * @param zkw
 * @param pathOrRegionName
 * @return Path to znode
 */
public static String getPath(final ZooKeeperWatcher zkw, final String pathOrRegionName) {
 return pathOrRegionName.startsWith("/")? pathOrRegionName : getNodeName(zkw, pathOrRegionName);
}

代码示例来源：origin: co.cask.hbase/hbase

/**
 * Get the version of the specified znode
 * @param zkw zk reference
 * @param region region's info
 * @return the version of the znode, -1 if it doesn't exist
 * @throws KeeperException
 */
public static int getVersion(ZooKeeperWatcher zkw, HRegionInfo region)
 throws KeeperException {
 String znode = getNodeName(zkw, region.getEncodedName());
 return ZKUtil.checkExists(zkw, znode);
}

代码示例来源：origin: harbby/presto-connectors

/**
 * Get the version of the specified znode
 * @param zkw zk reference
 * @param region region's info
 * @return the version of the znode, -1 if it doesn't exist
 * @throws KeeperException
 */
public static int getVersion(ZooKeeperWatcher zkw, HRegionInfo region)
 throws KeeperException {
 String znode = getNodeName(zkw, region.getEncodedName());
 return ZKUtil.checkExists(zkw, znode);
}

代码示例来源：origin: harbby/presto-connectors

/**
 * Delete the assignment node regardless of its current state.
 * <p>
 * Fail silent even if the node does not exist at all.
 * @param watcher
 * @param regionInfo
 * @throws KeeperException
 */
public static void deleteNodeFailSilent(ZooKeeperWatcher watcher,
  HRegionInfo regionInfo)
throws KeeperException {
 String node = getNodeName(watcher, regionInfo.getEncodedName());
 ZKUtil.deleteNodeFailSilent(watcher, node);
}

代码示例来源：origin: co.cask.hbase/hbase

/**
 * Delete the assignment node regardless of its current state.
 * <p>
 * Fail silent even if the node does not exist at all.
 * @param watcher
 * @param regionInfo
 * @throws KeeperException
 */
public static void deleteNodeFailSilent(ZooKeeperWatcher watcher,
  HRegionInfo regionInfo)
throws KeeperException {
 String node = getNodeName(watcher, regionInfo.getEncodedName());
 ZKUtil.deleteNodeFailSilent(watcher, node);
}

代码示例来源：origin: co.cask.hbase/hbase

/**
 * Gets the current data in the unassigned node for the specified region name
 * or fully-qualified path.
 *
 * <p>Returns null if the region does not currently have a node.
 *
 * <p>Does not set a watch.
 *
 * @param zkw zk reference
 * @param pathOrRegionName fully-specified path or region name
 * @param stat object to store node info into on getData call
 * @return data for the unassigned node or null if node does not exist
 * @throws KeeperException if unexpected zookeeper exception
 */
public static RegionTransitionData getDataNoWatch(ZooKeeperWatcher zkw,
  String pathOrRegionName, Stat stat)
throws KeeperException {
 String node = pathOrRegionName.startsWith("/") ?
   pathOrRegionName : getNodeName(zkw, pathOrRegionName);
 byte [] data = ZKUtil.getDataNoWatch(zkw, node, stat);
 if (data == null) {
  return null;
 }
 return RegionTransitionData.fromBytes(data);
}

代码示例来源：origin: co.cask.hbase/hbase

/**
 * Gets the current data in the unassigned node for the specified region name
 * or fully-qualified path.
 *
 * <p>Returns null if the region does not currently have a node.
 *
 * <p>Sets a watch on the node if the node exists.
 *
 * @param zkw zk reference
 * @param pathOrRegionName fully-specified path or region name
 * @return data for the unassigned node
 * @throws KeeperException if unexpected zookeeper exception
 */
public static RegionTransitionData getData(ZooKeeperWatcher zkw,
  String pathOrRegionName)
throws KeeperException {
 String node = pathOrRegionName.startsWith("/") ?
   pathOrRegionName : getNodeName(zkw, pathOrRegionName);
 byte [] data = ZKUtil.getDataAndWatch(zkw, node);
 if(data == null) {
  return null;
 }
 return RegionTransitionData.fromBytes(data);
}

代码示例来源：origin: co.cask.hbase/hbase

/**
 * Gets the current data in the unassigned node for the specified region name
 * or fully-qualified path.
 *
 * <p>Returns null if the region does not currently have a node.
 *
 * <p>Sets a watch on the node if the node exists.
 *
 * @param zkw zk reference
 * @param pathOrRegionName fully-specified path or region name
 * @param stat object to populate the version.
 * @return data for the unassigned node
 * @throws KeeperException if unexpected zookeeper exception
 */
public static RegionTransitionData getDataAndWatch(ZooKeeperWatcher zkw,
  String pathOrRegionName, Stat stat)
throws KeeperException {
 String node = pathOrRegionName.startsWith("/") ?
   pathOrRegionName : getNodeName(zkw, pathOrRegionName);
 byte [] data = ZKUtil.getDataAndWatch(zkw, node, stat);
 if(data == null) {
  return null;
 }
 return RegionTransitionData.fromBytes(data);
}

代码示例来源：origin: co.cask.hbase/hbase

String node = ZKAssign.getNodeName(watcher, regionInfo.getEncodedName());
Stat stat = new Stat();
RegionTransitionData dataInZNode = ZKAssign.getDataNoWatch(watcher, node,

代码示例来源：origin: co.cask.hbase/hbase

public static void createNodeOffline(ZooKeeperWatcher zkw, HRegionInfo region,
  ServerName serverName, final EventType event)
throws KeeperException, KeeperException.NodeExistsException {
 LOG.debug(zkw.prefix("Creating unassigned node for " +
  region.getEncodedName() + " in OFFLINE state"));
 RegionTransitionData data = new RegionTransitionData(event,
  region.getRegionName(), serverName);
 String node = getNodeName(zkw, region.getEncodedName());
 ZKUtil.createAndWatch(zkw, node, data.getBytes());
}

代码示例来源：origin: co.cask.hbase/hbase

/**
 * Creates a new ephemeral node in the SPLITTING state for the specified region.
 * Create it ephemeral in case regionserver dies mid-split.
 *
 * <p>Does not transition nodes from other states.  If a node already exists
 * for this region, a {@link NodeExistsException} will be thrown.
 *
 * @param zkw zk reference
 * @param region region to be created as offline
 * @param serverName server event originates from
 * @return Version of znode created.
 * @throws KeeperException 
 * @throws IOException 
 */
void createNodeSplitting(final ZooKeeperWatcher zkw, final HRegionInfo region,
  final ServerName serverName) throws KeeperException, IOException {
 LOG.debug(zkw.prefix("Creating ephemeral node for " +
  region.getEncodedName() + " in SPLITTING state"));
 RegionTransitionData data =
  new RegionTransitionData(EventType.RS_ZK_REGION_SPLITTING,
   region.getRegionName(), serverName);
 String node = ZKAssign.getNodeName(zkw, region.getEncodedName());
 if (!ZKUtil.createEphemeralNodeAndWatch(zkw, node, data.getBytes())) {
  throw new IOException("Failed create of ephemeral " + node);
 }
}

代码示例来源：origin: co.cask.hbase/hbase

/**
 * Creates an unassigned node in the OFFLINE state for the specified region.
 * <p>
 * Runs asynchronously.  Depends on no pre-existing znode.
 *
 * <p>Sets a watcher on the unassigned region node.
 *
 * @param zkw zk reference
 * @param region region to be created as offline
 * @param serverName server event originates from
 * @param cb
 * @param ctx
 * @throws KeeperException if unexpected zookeeper exception
 * @throws KeeperException.NodeExistsException if node already exists
 */
public static void asyncCreateNodeOffline(ZooKeeperWatcher zkw,
  HRegionInfo region, ServerName serverName,
  final AsyncCallback.StringCallback cb, final Object ctx)
throws KeeperException {
 LOG.debug(zkw.prefix("Async create of unassigned node for " +
  region.getEncodedName() + " with OFFLINE state"));
 RegionTransitionData data = new RegionTransitionData(
   EventType.M_ZK_REGION_OFFLINE, region.getRegionName(), serverName);
 String node = getNodeName(zkw, region.getEncodedName());
 ZKUtil.asyncCreate(zkw, node, data.getBytes(), cb, ctx);
}

代码示例来源：origin: co.cask.hbase/hbase

/**
 * Forces an existing unassigned node to the OFFLINE state for the specified
 * region.
 *
 * <p>Does not create a new node.  If a node does not already exist for this
 * region, a {@link NoNodeException} will be thrown.
 *
 * <p>Sets a watcher on the unassigned region node if the method is
 * successful.
 *
 * <p>This method should only be used during recovery of regionserver failure.
 *
 * @param zkw zk reference
 * @param region region to be forced as offline
 * @param serverName server event originates from
 * @throws KeeperException if unexpected zookeeper exception
 * @throws KeeperException.NoNodeException if node does not exist
 */
public static void forceNodeOffline(ZooKeeperWatcher zkw, HRegionInfo region,
  ServerName serverName)
throws KeeperException, KeeperException.NoNodeException {
 LOG.debug(zkw.prefix("Forcing existing unassigned node for " +
  region.getEncodedName() + " to OFFLINE state"));
 RegionTransitionData data = new RegionTransitionData(
   EventType.M_ZK_REGION_OFFLINE, region.getRegionName(), serverName);
 String node = getNodeName(zkw, region.getEncodedName());
 ZKUtil.setData(zkw, node, data.getBytes());
}

代码示例来源：origin: co.cask.hbase/hbase

EventType.M_ZK_REGION_CLOSING, region.getRegionName(), serverName);
String node = getNodeName(zkw, region.getEncodedName());
return ZKUtil.createAndWatch(zkw, node, data.getBytes());

代码示例来源：origin: harbby/presto-connectors

/**
 * Creates a new ephemeral node in the PENDING_MERGE state for the merged region.
 * Create it ephemeral in case regionserver dies mid-merge.
 *
 * <p>
 * Does not transition nodes from other states. If a node already exists for
 * this region, a {@link org.apache.zookeeper.KeeperException.NodeExistsException} will be thrown.
 *
 * @param region region to be created as offline
 * @param serverName server event originates from
 * @throws IOException
 */
@Override
public void startRegionMergeTransaction(final HRegionInfo region, final ServerName serverName,
  final HRegionInfo a, final HRegionInfo b) throws IOException {
 LOG.debug(watcher.prefix("Creating ephemeral node for " + region.getEncodedName()
   + " in PENDING_MERGE state"));
 byte[] payload = HRegionInfo.toDelimitedByteArray(region, a, b);
 RegionTransition rt =
   RegionTransition.createRegionTransition(RS_ZK_REQUEST_REGION_MERGE, region.getRegionName(),
    serverName, payload);
 String node = ZKAssign.getNodeName(watcher, region.getEncodedName());
 try {
  if (!ZKUtil.createEphemeralNodeAndWatch(watcher, node, rt.toByteArray())) {
   throw new IOException("Failed create of ephemeral " + node);
  }
 } catch (KeeperException e) {
  throw new IOException(e);
 }
}

代码示例来源：origin: harbby/presto-connectors

public static void createNodeOffline(ZooKeeperWatcher zkw, HRegionInfo region,
  ServerName serverName, final EventType event)
throws KeeperException, KeeperException.NodeExistsException {
 LOG.debug(zkw.prefix("Creating unassigned node " +
  region.getEncodedName() + " in OFFLINE state"));
 RegionTransition rt =
  RegionTransition.createRegionTransition(event, region.getRegionName(), serverName);
 String node = getNodeName(zkw, region.getEncodedName());
 ZKUtil.createAndWatch(zkw, node, rt.toByteArray());
}

代码示例来源：origin: harbby/presto-connectors

RegionTransition.createRegionTransition(RS_ZK_REQUEST_REGION_SPLIT,
   region.getRegionName(), serverName, payload);
String node = ZKAssign.getNodeName(watcher, region.getEncodedName());
if (!ZKUtil.createEphemeralNodeAndWatch(watcher, node, rt.toByteArray())) {
 throw new IOException("Failed create of ephemeral " + node);

代码示例来源：origin: harbby/presto-connectors

/**
 * Creates an unassigned node in the OFFLINE state for the specified region.
 * <p>
 * Runs asynchronously.  Depends on no pre-existing znode.
 *
 * <p>Sets a watcher on the unassigned region node.
 *
 * @param zkw zk reference
 * @param region region to be created as offline
 * @param serverName server transition will happen on
 * @param cb
 * @param ctx
 * @throws KeeperException if unexpected zookeeper exception
 * @throws KeeperException.NodeExistsException if node already exists
 */
public static void asyncCreateNodeOffline(ZooKeeperWatcher zkw,
  HRegionInfo region, ServerName serverName,
  final AsyncCallback.StringCallback cb, final Object ctx)
throws KeeperException {
 LOG.debug(zkw.prefix("Async create of unassigned node " +
  region.getEncodedName() + " with OFFLINE state"));
 RegionTransition rt =
  RegionTransition.createRegionTransition(
    EventType.M_ZK_REGION_OFFLINE, region.getRegionName(), serverName);
 String node = getNodeName(zkw, region.getEncodedName());
 ZKUtil.asyncCreate(zkw, node, rt.toByteArray(), cb, ctx);
}

代码示例来源：origin: harbby/presto-connectors

RegionTransition rt = RegionTransition.createRegionTransition(EventType.M_ZK_REGION_CLOSING,
 region.getRegionName(), serverName, HConstants.EMPTY_BYTE_ARRAY);
String node = getNodeName(zkw, region.getEncodedName());
return ZKUtil.createAndWatch(zkw, node, rt.toByteArray());

代码示例来源：origin: harbby/presto-connectors

String node = ZKAssign.getNodeName(watcher, encodedName);
Stat stat = new Stat();
try {