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

ZooKeeperWatcher.getMasterAddressZNode介绍

暂无

代码示例

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

/**
 * Construct a master address listener with the specified
 * <code>zookeeper</code> reference.
 * <p>
 * This constructor does not trigger any actions, you must call methods
 * explicitly.  Normally you will just want to execute {@link #start()} to
 * begin tracking of the master address.
 *
 * @param watcher zk reference and watcher
 * @param abortable abortable in case of fatal error
 */
public MasterAddressTracker(ZooKeeperWatcher watcher, Abortable abortable) {
 super(watcher, watcher.getMasterAddressZNode(), abortable);
}

代码示例来源：origin: com.aliyun.hbase/alihbase-client

/** Returns whether the znode is supposed to be readable by the client
 * and DOES NOT contain sensitive information (world readable).*/
public boolean isClientReadable(String node) {
 // Developer notice: These znodes are world readable. DO NOT add more znodes here UNLESS
 // all clients need to access this data to work. Using zk for sharing data to clients (other
 // than service lookup case is not a recommended design pattern.
 return
   node.equals(baseZNode) ||
   isAnyMetaReplicaZnode(node) ||
   node.equals(getMasterAddressZNode()) ||
   node.equals(clusterIdZNode)||
   node.equals(rsZNode) ||
   // /hbase/table and /hbase/table/foo is allowed, /hbase/table-lock is not
   node.equals(tableZNode) ||
   node.startsWith(tableZNode + "/");
}

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

/** Returns whether the znode is supposed to be readable by the client
 * and DOES NOT contain sensitive information (world readable).*/
public boolean isClientReadable(String node) {
 // Developer notice: These znodes are world readable. DO NOT add more znodes here UNLESS
 // all clients need to access this data to work. Using zk for sharing data to clients (other
 // than service lookup case is not a recommended design pattern.
 return
   node.equals(baseZNode) ||
   isAnyMetaReplicaZnode(node) ||
   node.equals(getMasterAddressZNode()) ||
   node.equals(clusterIdZNode)||
   node.equals(rsZNode) ||
   // /hbase/table and /hbase/table/foo is allowed, /hbase/table-lock is not
   node.equals(tableZNode) ||
   node.startsWith(tableZNode + "/");
}

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

void handle(final String path) {
 if (path.equals(watcher.getMasterAddressZNode()) && !master.isStopped()) {
  handleMasterNodeChange();
 }
}

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

/**
 * @return True if cluster has an active master.
 */
boolean hasActiveMaster() {
 try {
  if (ZKUtil.checkExists(watcher, watcher.getMasterAddressZNode()) >= 0) {
   return true;
  }
 }
 catch (KeeperException ke) {
  LOG.info("Received an unexpected KeeperException when checking " +
    "isActiveMaster : "+ ke);
 }
 return false;
}

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

/**
  * delete the master znode if its content is same as the parameter
  * @param zkw must not be null
  * @param content must not be null
  */
 public static boolean deleteIfEquals(ZooKeeperWatcher zkw, final String content) {
  if (content == null){
   throw new IllegalArgumentException("Content must not be null");
  }

  try {
   Stat stat = new Stat();
   byte[] data = ZKUtil.getDataNoWatch(zkw, zkw.getMasterAddressZNode(), stat);
   ServerName sn = ServerName.parseFrom(data);
   if (sn != null && content.equals(sn.toString())) {
    return (ZKUtil.deleteNode(zkw, zkw.getMasterAddressZNode(), stat.getVersion()));
   }
  } catch (KeeperException e) {
   LOG.warn("Can't get or delete the master znode", e);
  } catch (DeserializationException e) {
   LOG.warn("Can't get or delete the master znode", e);
  }

  return false;
 }
}

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

if (ZKUtil.watchAndCheckExists(watcher, watcher.getMasterAddressZNode())) {

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

/**
 * Get master address.
 * Use this instead of {@link #getMasterAddress()} if you do not have an
 * instance of this tracker in your context.
 * @param zkw ZooKeeperWatcher to use
 * @return ServerName stored in the the master address znode or null if no
 * znode present.
 * @throws KeeperException
 * @throws IOException
 */
public static ServerName getMasterAddress(final ZooKeeperWatcher zkw)
throws KeeperException, IOException {
 byte [] data;
 try {
  data = ZKUtil.getData(zkw, zkw.getMasterAddressZNode());
 } catch (InterruptedException e) {
  throw new InterruptedIOException();
 }
 // TODO javadoc claims we return null in this case. :/
 if (data == null){
  throw new IOException("Can't get master address from ZooKeeper; znode data == null");
 }
 try {
  return ServerName.parseFrom(data);
 } catch (DeserializationException e) {
  KeeperException ke = new KeeperException.DataInconsistencyException();
  ke.initCause(e);
  throw ke;
 }
}

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

byte[] data;
try {
 data = ZKUtil.getData(zkw, zkw.getMasterAddressZNode());
} catch (InterruptedException e) {
 throw new InterruptedIOException();

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

public void stop() {
  try {
   synchronized (clusterHasActiveMaster) {
    // Master is already stopped, wake up the manager
    // thread so that it can shutdown soon.
    clusterHasActiveMaster.notifyAll();
   }
   // If our address is in ZK, delete it on our way out
   ServerName activeMaster = null;
   try {
    activeMaster = MasterAddressTracker.getMasterAddress(this.watcher);
   } catch (IOException e) {
    LOG.warn("Failed get of master address: " + e.toString());
   }
   if (activeMaster != null &&  activeMaster.equals(this.sn)) {
    ZKUtil.deleteNode(watcher, watcher.getMasterAddressZNode());
    // We may have failed to delete the znode at the previous step, but
    //  we delete the file anyway: a second attempt to delete the znode is likely to fail again.
    ZNodeClearer.deleteMyEphemeralNodeOnDisk();
   }
  } catch (KeeperException e) {
   LOG.error(this.watcher.prefix("Error deleting our own master address node"), e);
  }
 }
}

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

if (ZKUtil.checkExists(zkw, zkw.getMasterAddressZNode()) != -1) {
 byte[] data = ZKUtil.getData(zkw, zkw.getMasterAddressZNode());
 if (data != null && !Bytes.equals(data, HConstants.EMPTY_BYTE_ARRAY)) {
  LOG.warn("Active master at address " + Bytes.toString(data)

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

this.watcher.getMasterAddressZNode(), this.sn, infoPort)) {
 ZKUtil.getDataAndWatch(this.watcher, this.watcher.getMasterAddressZNode());
if (bytes == null) {
 msg = ("A master was detected, but went down before its address " +
   currentMaster + "; master was restarted? Deleting node.");
  ZKUtil.deleteNode(this.watcher, this.watcher.getMasterAddressZNode());