gpt4 book ai didi

org.apache.hadoop.hive.ql.lockmgr.zookeeper.ZooKeeperHiveLockManager.getLastObjectName()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-14 18:07:31 26 4
gpt4 key购买 nike

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

ZooKeeperHiveLockManager.getLastObjectName介绍

暂无

代码示例

代码示例来源:origin: apache/hive

HiveLockMode lMode = hiveLock.getHiveLockMode();
HiveLockObject obj = zLock.getHiveLockObject();
String name  = getLastObjectName(parent, obj);
try {

代码示例来源:origin: apache/drill

HiveLockMode lMode = hiveLock.getHiveLockMode();
HiveLockObject obj = zLock.getHiveLockObject();
String name  = getLastObjectName(parent, obj);
try {

代码示例来源:origin: apache/hive

lastName = getLastObjectName(parent, key);
 names.add(lastName);
} else {

代码示例来源:origin: apache/drill

lastName = getLastObjectName(parent, key);
 names.add(lastName);
} else {

代码示例来源:origin: org.apache.hadoop.hive/hive-exec

private static void unlock(HiveConf conf, ZooKeeper zkpClient,
              HiveLock hiveLock, String parent) throws LockException {
 ZooKeeperHiveLock zLock = (ZooKeeperHiveLock)hiveLock;
 try {
  zkpClient.delete(zLock.getPath(), -1);
  // Delete the parent node if all the children have been deleted
  HiveLockObject obj = zLock.getHiveLockObject();
  String name  = getLastObjectName(parent, obj);
  List<String> children = zkpClient.getChildren(name, false);
  if ((children == null) || (children.isEmpty()))
  {
   zkpClient.delete(name, -1);
  }
 } catch (Exception e) {
  LOG.error("Failed to release ZooKeeper lock: " + e);
  throw new LockException(e);
 }
}

代码示例来源:origin: com.facebook.presto.hive/hive-apache

@VisibleForTesting
static void unlockPrimitive(HiveLock hiveLock, String parent, CuratorFramework curatorFramework) throws LockException {
 ZooKeeperHiveLock zLock = (ZooKeeperHiveLock)hiveLock;
 HiveLockObject obj = zLock.getHiveLockObject();
 String name  = getLastObjectName(parent, obj);
 try {
  curatorFramework.delete().forPath(zLock.getPath());
  // Delete the parent node if all the children have been deleted
  List<String> children = curatorFramework.getChildren().forPath(name);
  if (children == null || children.isEmpty()) {
   curatorFramework.delete().forPath(name);
  }
 } catch (KeeperException.NoNodeException nne) {
  //can happen in retrying deleting the zLock after exceptions like InterruptedException
  //or in a race condition where parent has already been deleted by other process when it
  //is to be deleted. Both cases should not raise error
  LOG.debug("Node " + zLock.getPath() + " or its parent has already been deleted.");
 } catch (KeeperException.NotEmptyException nee) {
  //can happen in a race condition where another process adds a zLock under this parent
  //just before it is about to be deleted. It should not be a problem since this parent
  //can eventually be deleted by the process which hold its last child zLock
  LOG.debug("Node " + name + " to be deleted is not empty.");
 } catch (Exception e) {
  //exceptions including InterruptException and other KeeperException
  LOG.error("Failed to release ZooKeeper lock: ", e);
  throw new LockException(e);
 }
}

代码示例来源:origin: com.facebook.presto.hive/hive-apache

lastName = getLastObjectName(parent, key);
 names.add(lastName);
} else {

代码示例来源:origin: org.apache.hadoop.hive/hive-exec

lastName = getLastObjectName(parent, key);
names.add(lastName);

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com