gpt4 book ai didi

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

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

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

ZooKeeperHiveLockManager.getLockMode介绍

暂无

代码示例

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

private void checkRedundantNode(String node) {
 try {
  // Nothing to do if it is a lock mode
  if (getLockMode(node) != null) {
   return;
  }
  List<String> children = curatorFramework.getChildren().forPath(node);
  for (String child : children) {
   checkRedundantNode(node + "/" + child);
  }
  children = curatorFramework.getChildren().forPath(node);
  if ((children == null) || (children.isEmpty()))
  {
   curatorFramework.delete().forPath(node);
  }
 } catch (Exception e) {
  LOG.warn("Error in checkRedundantNode for node " + node, e);
 }
}

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

private void checkRedundantNode(String node) {
 try {
  // Nothing to do if it is a lock mode
  if (getLockMode(node) != null) {
   return;
  }
  List<String> children = curatorFramework.getChildren().forPath(node);
  for (String child : children) {
   checkRedundantNode(node + "/" + child);
  }
  children = curatorFramework.getChildren().forPath(node);
  if ((children == null) || (children.isEmpty()))
  {
   curatorFramework.delete().forPath(node);
  }
 } catch (Exception e) {
  LOG.warn("Error in checkRedundantNode for node " + node, e);
 }
}

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

HiveLockMode mode = getLockMode(curChild);
if (mode == null) {
 continue;

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

HiveLockMode mode = getLockMode(curChild);
if (mode == null) {
 continue;

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

private void checkRedundantNode(String node) {
 try {
  // Nothing to do if it is a lock mode
  if (getLockMode(node) != null) {
   return;
  }
  List<String> children = curatorFramework.getChildren().forPath(node);
  for (String child : children) {
   checkRedundantNode(node + "/" + child);
  }
  children = curatorFramework.getChildren().forPath(node);
  if ((children == null) || (children.isEmpty()))
  {
   curatorFramework.delete().forPath(node);
  }
 } catch (Exception e) {
  LOG.warn("Error in checkRedundantNode for node " + node, e);
 }
}

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

private void checkRedundantNode(String node) {
 try {
  // Nothing to do if it is a lock mode
  if (getLockMode(ctx.getConf(), node) != null)
   return;
  List<String> children = zooKeeper.getChildren(node, false);
  for (String child : children) {
   checkRedundantNode(node + "/" + child);
  }
  children = zooKeeper.getChildren(node, false);
  if ((children == null) || (children.isEmpty()))
  {
   zooKeeper.delete(node, -1);
  }
 } catch (Exception e) {
  // ignore all errors
 }
}

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

HiveLockMode mode = getLockMode(conf, curChild);
if (mode == null) {
 continue;

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

HiveLockMode mode = getLockMode(curChild);
if (mode == null) {
 continue;

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