gpt4 book ai didi

org.apache.hadoop.hive.thrift.ZooKeeperTokenStore.zkGetChildren()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-17 04:45:31 27 4
gpt4 key购买 nike

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

ZooKeeperTokenStore.zkGetChildren介绍

暂无

代码示例

代码示例来源:origin: org.apache.hive.shims/hive-shims-common-secure

@Override
public List<DelegationTokenIdentifier> getAllDelegationTokenIdentifiers() {
 String containerNode = rootNode + NODE_TOKENS;
 final List<String> nodes = zkGetChildren(containerNode);
 List<DelegationTokenIdentifier> result = new java.util.ArrayList<DelegationTokenIdentifier>(
   nodes.size());
 for (String node : nodes) {
  DelegationTokenIdentifier id = new DelegationTokenIdentifier();
  try {
   TokenStoreDelegationTokenSecretManager.decodeWritable(id, node);
   result.add(id);
  } catch (Exception e) {
   LOGGER.warn("Failed to decode token '{}'", node);
  }
 }
 return result;
}

代码示例来源:origin: com.github.hyukjinkwon.shims/hive-shims-common

@Override
public List<DelegationTokenIdentifier> getAllDelegationTokenIdentifiers() {
 String containerNode = rootNode + NODE_TOKENS;
 final List<String> nodes = zkGetChildren(containerNode);
 List<DelegationTokenIdentifier> result = new java.util.ArrayList<DelegationTokenIdentifier>(
   nodes.size());
 for (String node : nodes) {
  DelegationTokenIdentifier id = new DelegationTokenIdentifier();
  try {
   TokenStoreDelegationTokenSecretManager.decodeWritable(id, node);
   result.add(id);
  } catch (Exception e) {
   LOGGER.warn("Failed to decode token '{}'", node);
  }
 }
 return result;
}

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

private Map<Integer, byte[]> getAllKeys() throws KeeperException, InterruptedException {
 String masterKeyNode = rootNode + NODE_KEYS;
 // get children of key node
 List<String> nodes = zkGetChildren(masterKeyNode);
 // read each child node, add to results
 Map<Integer, byte[]> result = new HashMap<Integer, byte[]>();
 for (String node : nodes) {
  String nodePath = masterKeyNode + "/" + node;
  byte[] data = zkGetData(nodePath);
  if (data != null) {
   result.put(getSeq(node), data);
  }
 }
 return result;
}

代码示例来源:origin: org.apache.hive.shims/hive-shims-common-secure

private Map<Integer, byte[]> getAllKeys() throws KeeperException, InterruptedException {
 String masterKeyNode = rootNode + NODE_KEYS;
 // get children of key node
 List<String> nodes = zkGetChildren(masterKeyNode);
 // read each child node, add to results
 Map<Integer, byte[]> result = new HashMap<Integer, byte[]>();
 for (String node : nodes) {
  String nodePath = masterKeyNode + "/" + node;
  byte[] data = zkGetData(nodePath);
  if (data != null) {
   result.put(getSeq(node), data);
  }
 }
 return result;
}

代码示例来源:origin: com.github.hyukjinkwon.shims/hive-shims-common

private Map<Integer, byte[]> getAllKeys() throws KeeperException, InterruptedException {
 String masterKeyNode = rootNode + NODE_KEYS;
 // get children of key node
 List<String> nodes = zkGetChildren(masterKeyNode);
 // read each child node, add to results
 Map<Integer, byte[]> result = new HashMap<Integer, byte[]>();
 for (String node : nodes) {
  String nodePath = masterKeyNode + "/" + node;
  byte[] data = zkGetData(nodePath);
  if (data != null) {
   result.put(getSeq(node), data);
  }
 }
 return result;
}

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

@Override
public List<DelegationTokenIdentifier> getAllDelegationTokenIdentifiers() {
 String containerNode = rootNode + NODE_TOKENS;
 final List<String> nodes = zkGetChildren(containerNode);
 List<DelegationTokenIdentifier> result = new java.util.ArrayList<DelegationTokenIdentifier>(
   nodes.size());
 for (String node : nodes) {
  DelegationTokenIdentifier id = new DelegationTokenIdentifier();
  try {
   TokenStoreDelegationTokenSecretManager.decodeWritable(id, node);
   result.add(id);
  } catch (Exception e) {
   LOGGER.warn("Failed to decode token '{}'", node);
  }
 }
 return result;
}

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