本文整理了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
暂无
代码示例来源: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);
内容来源于网络,如有侵权,请联系作者删除!