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

ZKUtil.logRetrievedMsg介绍

暂无

代码示例

代码示例来源：origin: apache/hbase

/**
 * Get znode data. Does not set a watcher.
 *
 * @return ZNode data, null if the node does not exist or if there is an error.
 */
public static byte [] getData(ZKWatcher zkw, String znode)
  throws KeeperException, InterruptedException {
 try {
  byte [] data = zkw.getRecoverableZooKeeper().getData(znode, null, null);
  logRetrievedMsg(zkw, znode, data, false);
  return data;
 } catch (KeeperException.NoNodeException e) {
  LOG.debug(zkw.prefix("Unable to get data of znode " + znode + " " +
    "because node does not exist (not an error)"));
  return null;
 } catch (KeeperException e) {
  LOG.warn(zkw.prefix("Unable to get data of znode " + znode), e);
  zkw.keeperException(e);
  return null;
 }
}

代码示例来源：origin: apache/hbase

private static byte[] getDataInternal(ZKWatcher zkw, String znode, Stat stat,
                   boolean watcherSet)
  throws KeeperException {
 try {
  byte [] data = zkw.getRecoverableZooKeeper().getData(znode, zkw, stat);
  logRetrievedMsg(zkw, znode, data, watcherSet);
  return data;
 } catch (KeeperException.NoNodeException e) {
  // This log can get pretty annoying when we cycle on 100ms waits.
  // Enable trace if you really want to see it.
  LOG.trace(zkw.prefix("Unable to get data of znode " + znode + " " +
   "because node does not exist (not an error)"));
  return null;
 } catch (KeeperException e) {
  LOG.warn(zkw.prefix("Unable to get data of znode " + znode), e);
  zkw.keeperException(e);
  return null;
 } catch (InterruptedException e) {
  LOG.warn(zkw.prefix("Unable to get data of znode " + znode), e);
  zkw.interruptedException(e);
  return null;
 }
}

代码示例来源：origin: apache/hbase

try {
 byte [] data = zkw.getRecoverableZooKeeper().getData(znode, null, stat);
 logRetrievedMsg(zkw, znode, data, false);
 return data;
} catch (KeeperException.NoNodeException e) {

代码示例来源：origin: org.apache.hbase/hbase-zookeeper

/**
 * Get znode data. Does not set a watcher.
 *
 * @return ZNode data, null if the node does not exist or if there is an error.
 */
public static byte [] getData(ZKWatcher zkw, String znode)
  throws KeeperException, InterruptedException {
 try {
  byte [] data = zkw.getRecoverableZooKeeper().getData(znode, null, null);
  logRetrievedMsg(zkw, znode, data, false);
  return data;
 } catch (KeeperException.NoNodeException e) {
  LOG.debug(zkw.prefix("Unable to get data of znode " + znode + " " +
    "because node does not exist (not an error)"));
  return null;
 } catch (KeeperException e) {
  LOG.warn(zkw.prefix("Unable to get data of znode " + znode), e);
  zkw.keeperException(e);
  return null;
 }
}

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

/**
 * Get znode data. Does not set a watcher.
 * @return ZNode data
 */
public static byte [] getData(ZooKeeperWatcher zkw, String znode)
throws KeeperException {
 try {
  byte [] data = zkw.getRecoverableZooKeeper().getData(znode, null, null);
  logRetrievedMsg(zkw, znode, data, false);
  return data;
 } catch (KeeperException.NoNodeException e) {
  LOG.debug(zkw.prefix("Unable to get data of znode " + znode + " " +
   "because node does not exist (not an error)"));
  return null;
 } catch (KeeperException e) {
  LOG.warn(zkw.prefix("Unable to get data of znode " + znode), e);
  zkw.keeperException(e);
  return null;
 } catch (InterruptedException e) {
  LOG.warn(zkw.prefix("Unable to get data of znode " + znode), e);
  zkw.interruptedException(e);
  return null;
 }
}

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

private static byte[] getDataInternal(ZooKeeperWatcher zkw, String znode, Stat stat,
  boolean watcherSet)
  throws KeeperException {
 try {
  byte [] data = zkw.getRecoverableZooKeeper().getData(znode, zkw, stat);
  logRetrievedMsg(zkw, znode, data, watcherSet);
  return data;
 } catch (KeeperException.NoNodeException e) {
  LOG.debug(zkw.prefix("Unable to get data of znode " + znode + " " +
   "because node does not exist (not an error)"));
  return null;
 } catch (KeeperException e) {
  LOG.warn(zkw.prefix("Unable to get data of znode " + znode), e);
  zkw.keeperException(e);
  return null;
 } catch (InterruptedException e) {
  LOG.warn(zkw.prefix("Unable to get data of znode " + znode), e);
  zkw.interruptedException(e);
  return null;
 }
}

代码示例来源：origin: org.apache.hbase/hbase-zookeeper

private static byte[] getDataInternal(ZKWatcher zkw, String znode, Stat stat,
                   boolean watcherSet)
  throws KeeperException {
 try {
  byte [] data = zkw.getRecoverableZooKeeper().getData(znode, zkw, stat);
  logRetrievedMsg(zkw, znode, data, watcherSet);
  return data;
 } catch (KeeperException.NoNodeException e) {
  // This log can get pretty annoying when we cycle on 100ms waits.
  // Enable trace if you really want to see it.
  LOG.trace(zkw.prefix("Unable to get data of znode " + znode + " " +
   "because node does not exist (not an error)"));
  return null;
 } catch (KeeperException e) {
  LOG.warn(zkw.prefix("Unable to get data of znode " + znode), e);
  zkw.keeperException(e);
  return null;
 } catch (InterruptedException e) {
  LOG.warn(zkw.prefix("Unable to get data of znode " + znode), e);
  zkw.interruptedException(e);
  return null;
 }
}

代码示例来源：origin: org.apache.hbase/hbase-zookeeper

try {
 byte [] data = zkw.getRecoverableZooKeeper().getData(znode, null, stat);
 logRetrievedMsg(zkw, znode, data, false);
 return data;
} catch (KeeperException.NoNodeException e) {

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

try {
 byte [] data = zkw.getRecoverableZooKeeper().getData(znode, null, stat);
 logRetrievedMsg(zkw, znode, data, false);
 return data;
} catch (KeeperException.NoNodeException e) {

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

/**
 * Get znode data. Does not set a watcher.
 * @return ZNode data, null if the node does not exist or if there is an
 *  error.
 */
public static byte [] getData(ZooKeeperWatcher zkw, String znode)
  throws KeeperException, InterruptedException {
 try {
  byte [] data = zkw.getRecoverableZooKeeper().getData(znode, null, null);
  logRetrievedMsg(zkw, znode, data, false);
  return data;
 } catch (KeeperException.NoNodeException e) {
  LOG.debug(zkw.prefix("Unable to get data of znode " + znode + " " +
    "because node does not exist (not an error)"));
  return null;
 } catch (KeeperException e) {
  LOG.warn(zkw.prefix("Unable to get data of znode " + znode), e);
  zkw.keeperException(e);
  return null;
 }
}

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

private static byte[] getDataInternal(ZooKeeperWatcher zkw, String znode, Stat stat,
  boolean watcherSet)
  throws KeeperException {
 try {
  byte [] data = zkw.getRecoverableZooKeeper().getData(znode, zkw, stat);
  logRetrievedMsg(zkw, znode, data, watcherSet);
  return data;
 } catch (KeeperException.NoNodeException e) {
  // This log can get pretty annoying when we cycle on 100ms waits.
  // Enable trace if you really want to see it.
  LOG.trace(zkw.prefix("Unable to get data of znode " + znode + " " +
   "because node does not exist (not an error)"));
  return null;
 } catch (KeeperException e) {
  LOG.warn(zkw.prefix("Unable to get data of znode " + znode), e);
  zkw.keeperException(e);
  return null;
 } catch (InterruptedException e) {
  LOG.warn(zkw.prefix("Unable to get data of znode " + znode), e);
  zkw.interruptedException(e);
  return null;
 }
}

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

try {
 byte [] data = zkw.getRecoverableZooKeeper().getData(znode, null, stat);
 logRetrievedMsg(zkw, znode, data, false);
 return data;
} catch (KeeperException.NoNodeException e) {