org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher.interruptedException()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(13.7k)|赞(0)|评价(0)|浏览(81)

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

ZooKeeperWatcher.interruptedException介绍

[英]Handles InterruptedExceptions in client calls.

This may be temporary but for now this gives one place to deal with these.

TODO: Currently, this method does nothing. Is this ever expected to happen? Do we abort or can we let it run? Maybe this should be logged as WARN? It shouldn't happen?
[中]处理客户端调用中的中断异常。
这可能是暂时的，但就目前而言，这为解决这些问题提供了一个空间。
TODO：目前，这种方法不起任何作用。这会发生吗？我们是中止还是让它运行？也许这应该记录为警告？这不应该发生吗？

代码示例

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

/**
 * Delete the specified node with the specified version.  Sets no watches.
 * Throws all exceptions.
 */
public static boolean deleteNode(ZooKeeperWatcher zkw, String node,
  int version)
throws KeeperException {
 try {
  zkw.getRecoverableZooKeeper2().delete(node, version);
  return true;
 } catch(KeeperException.BadVersionException bve) {
  return false;
 } catch(InterruptedException ie) {
  zkw.interruptedException(ie);
  return false;
 }
}

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

/**
 * Delete the specified node with the specified version.  Sets no watches.
 * Throws all exceptions.
 */
public static boolean deleteNode(ZooKeeperWatcher zkw, String node,
  int version)
throws KeeperException {
 try {
  zkw.getRecoverableZooKeeper().delete(node, version);
  return true;
 } catch(KeeperException.BadVersionException bve) {
  return false;
 } catch(InterruptedException ie) {
  zkw.interruptedException(ie);
  return false;
 }
}

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

/**
 * Delete the specified node with the specified version.  Sets no watches.
 * Throws all exceptions.
 */
public static boolean deleteNode(ZooKeeperWatcher zkw, String node,
  int version)
throws KeeperException {
 try {
  zkw.getRecoverableZooKeeper().delete(node, version);
  return true;
 } catch(KeeperException.BadVersionException bve) {
  return false;
 } catch(InterruptedException ie) {
  zkw.interruptedException(ie);
  return false;
 }
}

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

/**
 * Update the data of an existing node with the expected version to have the
 * specified data.
 *
 * Throws an exception if there is a version mismatch or some other problem.
 *
 * Sets no watches under any conditions.
 *
 * @param zkw zk reference
 * @param znode
 * @param data
 * @param expectedVersion
 * @throws KeeperException if unexpected zookeeper exception
 * @throws KeeperException.BadVersionException if version mismatch
 */
public static void updateExistingNodeData(ZooKeeperWatcher zkw, String znode,
  byte [] data, int expectedVersion)
throws KeeperException {
 try {
  zkw.getRecoverableZooKeeper().setData(znode, data, expectedVersion);
 } catch(InterruptedException ie) {
  zkw.interruptedException(ie);
 }
}

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

/**
 * Watch the specified znode, but only if exists. Useful when watching
 * for deletions. Uses .getData() (and handles NoNodeException) instead
 * of .exists() to accomplish this, as .getData() will only set a watch if
 * the znode exists.
 * @param zkw zk reference
 * @param znode path of node to watch
 * @return true if the watch is set, false if node does not exists
 * @throws KeeperException if unexpected zookeeper exception
 */
public static boolean setWatchIfNodeExists(ZooKeeperWatcher zkw, String znode)
  throws KeeperException {
 try {
  zkw.getRecoverableZooKeeper2().getData(znode, true, null);
  return true;
 } catch (NoNodeException e) {
  return false;
 } catch (InterruptedException e) {
  LOG.warn(zkw.prefix("Unable to set watcher on znode " + znode), e);
  zkw.interruptedException(e);
  return false;
 }
}

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

private static void appendPeerState(ZooKeeperWatcher zkw, String znodeToProcess,
  StringBuilder sb) throws KeeperException, InvalidProtocolBufferException {
 String peerState = zkw.getConfiguration().get("zookeeper.znode.replication.peers.state",
  "peer-state");
 int pblen = ProtobufUtil.lengthOfPBMagic();
 for (String child : ZKUtil2.listChildrenNoWatch(zkw, znodeToProcess)) {
  if (!child.equals(peerState)) continue;
  String peerStateZnode = ZKUtil2.joinZNode(znodeToProcess, child);
  sb.append("\n").append(peerStateZnode).append(": ");
  byte[] peerStateData;
  try {
   peerStateData = ZKUtil2.getData(zkw, peerStateZnode);
   ZooKeeperProtos.ReplicationState.Builder builder =
     ZooKeeperProtos.ReplicationState.newBuilder();
   ProtobufUtil.mergeFrom(builder, peerStateData, pblen, peerStateData.length - pblen);
   sb.append(builder.getState().name());
  } catch (IOException ipbe) {
   LOG.warn("Got Exception while parsing peer: " + znodeToProcess, ipbe);
  } catch (InterruptedException e) {
   zkw.interruptedException(e);
   return;
  }
 }
}

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

private static byte[] getDataInternal(ZooKeeperWatcher zkw, String znode, Stat stat,
   boolean watcherSet)
   throws KeeperException {
  try {
   byte [] data = zkw.getRecoverableZooKeeper2().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: co.cask.hbase/hbase

/**
 * Check if the specified node exists.  Sets no watches.
 *
 * @param zkw zk reference
 * @param znode path of node to watch
 * @return version of the node if it exists, -1 if does not exist
 * @throws KeeperException if unexpected zookeeper exception
 */
public static int checkExists(ZooKeeperWatcher zkw, String znode)
throws KeeperException {
 try {
  Stat s = zkw.getRecoverableZooKeeper().exists(znode, null);
  return s != null ? s.getVersion() : -1;
 } catch (KeeperException e) {
  LOG.warn(zkw.prefix("Unable to set watcher on znode (" + znode + ")"), e);
  zkw.keeperException(e);
  return -1;
 } catch (InterruptedException e) {
  LOG.warn(zkw.prefix("Unable to set watcher on znode (" + znode + ")"), e);
  zkw.interruptedException(e);
  return -1;
 }
}

代码示例来源：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: 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: com.aliyun.hbase/alihbase-client

/**
 * Check if the specified node exists.  Sets no watches.
 *
 * @param zkw zk reference
 * @param znode path of node to watch
 * @return version of the node if it exists, -1 if does not exist
 * @throws KeeperException if unexpected zookeeper exception
 */
public static int checkExists(ZooKeeperWatcher zkw, String znode)
throws KeeperException {
 try {
  Stat s = zkw.getRecoverableZooKeeper2().exists(znode, null);
  return s != null ? s.getVersion() : -1;
 } catch (KeeperException e) {
  LOG.warn(zkw.prefix("Unable to set watcher on znode (" + znode + ")"), e);
  zkw.keeperException(e);
  return -1;
 } catch (InterruptedException e) {
  LOG.warn(zkw.prefix("Unable to set watcher on znode (" + znode + ")"), e);
  zkw.interruptedException(e);
  return -1;
 }
}

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

/**
 * Delete the specified node and all of it's children.
 * <p>
 * If the node does not exist, just returns.
 * <p>
 * Sets no watches. Throws all exceptions besides dealing with deletion of
 * children.
 */
public static void deleteNodeRecursively(ZooKeeperWatcher zkw, String node)
throws KeeperException {
 try {
  List<String> children = ZKUtil.listChildrenNoWatch(zkw, node);
  // the node is already deleted, so we just finish
  if (children == null) return;
  if(!children.isEmpty()) {
   for(String child : children) {
    deleteNodeRecursively(zkw, joinZNode(node, child));
   }
  }
  zkw.getRecoverableZooKeeper().delete(node, -1);
 } catch(InterruptedException ie) {
  zkw.interruptedException(ie);
 }
}

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

private static void deleteNodeFailSilent(ZooKeeperWatcher zkw,
  DeleteNodeFailSilent dnfs) throws KeeperException {
 DeleteRequest delete = (DeleteRequest)toZooKeeperOp(zkw, dnfs).toRequestRecord();
 try {
  zkw.getRecoverableZooKeeper().delete(delete.getPath(), delete.getVersion());
 } catch(KeeperException.NoNodeException nne) {
 } catch(InterruptedException ie) {
  zkw.interruptedException(ie);
 }
}

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

/**
 * Watch the specified znode, but only if exists. Useful when watching
 * for deletions. Uses .getData() (and handles NoNodeException) instead
 * of .exists() to accomplish this, as .getData() will only set a watch if
 * the znode exists.
 * @param zkw zk reference
 * @param znode path of node to watch
 * @return true if the watch is set, false if node does not exists
 * @throws KeeperException if unexpected zookeeper exception
 */
public static boolean setWatchIfNodeExists(ZooKeeperWatcher zkw, String znode)
  throws KeeperException {
 try {
  zkw.getRecoverableZooKeeper().getData(znode, true, null);
  return true;
 } catch (NoNodeException e) {
  return false;
 } catch (InterruptedException e) {
  LOG.warn(zkw.prefix("Unable to set watcher on znode " + znode), e);
  zkw.interruptedException(e);
  return false;
 }
}

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

private static void deleteNodeFailSilent(ZooKeeperWatcher zkw,
  DeleteNodeFailSilent dnfs) throws KeeperException {
 DeleteRequest delete = (DeleteRequest)toZooKeeperOp(zkw, dnfs).toRequestRecord();
 try {
  zkw.getRecoverableZooKeeper2().delete(delete.getPath(), delete.getVersion());
 } catch(KeeperException.NoNodeException nne) {
 } catch(InterruptedException ie) {
  zkw.interruptedException(ie);
 }
}

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

private static void deleteNodeFailSilent(ZooKeeperWatcher zkw,
  DeleteNodeFailSilent dnfs) throws KeeperException {
 DeleteRequest delete = (DeleteRequest)toZooKeeperOp(zkw, dnfs).toRequestRecord();
 try {
  zkw.getRecoverableZooKeeper().delete(delete.getPath(), delete.getVersion());
 } catch(KeeperException.NoNodeException nne) {
 } catch(InterruptedException ie) {
  zkw.interruptedException(ie);
 }
}

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

private static void createAndFailSilent(ZooKeeperWatcher zkw, CreateAndFailSilent cafs)
throws KeeperException {
 CreateRequest create = (CreateRequest)toZooKeeperOp(zkw, cafs).toRequestRecord();
 String znode = create.getPath();
 try {
  RecoverableZooKeeper2 zk = zkw.getRecoverableZooKeeper2();
  if (zk.exists(znode, false) == null) {
   zk.create(znode, create.getData(), create.getAcl(), CreateMode.fromFlag(create.getFlags()));
  }
 } catch(KeeperException.NodeExistsException nee) {
 } catch(KeeperException.NoAuthException nee){
  try {
   if (null == zkw.getRecoverableZooKeeper2().exists(znode, false)) {
    // If we failed to create the file and it does not already exist.
    throw(nee);
   }
  } catch (InterruptedException ie) {
   zkw.interruptedException(ie);
  }
 } catch(InterruptedException ie) {
  zkw.interruptedException(ie);
 }
}

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

private static void createAndFailSilent(ZooKeeperWatcher zkw, CreateAndFailSilent cafs)
throws KeeperException {
 CreateRequest create = (CreateRequest)toZooKeeperOp(zkw, cafs).toRequestRecord();
 String znode = create.getPath();
 try {
  RecoverableZooKeeper zk = zkw.getRecoverableZooKeeper();
  if (zk.exists(znode, false) == null) {
   zk.create(znode, create.getData(), create.getAcl(), CreateMode.fromFlag(create.getFlags()));
  }
 } catch(KeeperException.NodeExistsException nee) {
 } catch(KeeperException.NoAuthException nee){
  try {
   if (null == zkw.getRecoverableZooKeeper().exists(znode, false)) {
    // If we failed to create the file and it does not already exist.
    throw(nee);
   }
  } catch (InterruptedException ie) {
   zkw.interruptedException(ie);
  }
 } catch(InterruptedException ie) {
  zkw.interruptedException(ie);
 }
}

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

private static void createAndFailSilent(ZooKeeperWatcher zkw, CreateAndFailSilent cafs)
throws KeeperException {
 CreateRequest create = (CreateRequest)toZooKeeperOp(zkw, cafs).toRequestRecord();
 String znode = create.getPath();
 try {
  RecoverableZooKeeper zk = zkw.getRecoverableZooKeeper();
  if (zk.exists(znode, false) == null) {
   zk.create(znode, create.getData(), create.getAcl(), CreateMode.fromFlag(create.getFlags()));
  }
 } catch(KeeperException.NodeExistsException nee) {
 } catch(KeeperException.NoAuthException nee){
  try {
   if (null == zkw.getRecoverableZooKeeper().exists(znode, false)) {
    // If we failed to create the file and it does not already exist.
    throw(nee);
   }
  } catch (InterruptedException ie) {
   zkw.interruptedException(ie);
  }
 } catch(InterruptedException ie) {
  zkw.interruptedException(ie);
 }
}

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

/**
 * Check if the specified node exists.  Sets no watches.
 *
 * @param zkw zk reference
 * @param znode path of node to watch
 * @return version of the node if it exists, -1 if does not exist
 * @throws KeeperException if unexpected zookeeper exception
 */
public static int checkExists(ZooKeeperWatcher zkw, String znode)
throws KeeperException {
 try {
  Stat s = zkw.getRecoverableZooKeeper().exists(znode, null);
  return s != null ? s.getVersion() : -1;
 } catch (KeeperException e) {
  LOG.warn(zkw.prefix("Unable to set watcher on znode (" + znode + ")"), e);
  zkw.keeperException(e);
  return -1;
 } catch (InterruptedException e) {
  LOG.warn(zkw.prefix("Unable to set watcher on znode (" + znode + ")"), e);
  zkw.interruptedException(e);
  return -1;
 }
}

内容来源于网络，如有侵权，请联系作者删除！

ZooKeeperWatcher

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com