org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager.getNodePath()方法的使用及代码示例

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

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

ZKDelegationTokenSecretManager.getNodePath介绍

暂无

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-common

private DelegationKey getKeyFromZK(int keyId) throws IOException {
 String nodePath =
   getNodePath(ZK_DTSM_MASTER_KEY_ROOT, DELEGATION_KEY_PREFIX + keyId);
 try {
  byte[] data = zkClient.getData().forPath(nodePath);
  if ((data == null) || (data.length == 0)) {
   return null;
  }
  ByteArrayInputStream bin = new ByteArrayInputStream(data);
  DataInputStream din = new DataInputStream(bin);
  DelegationKey key = new DelegationKey();
  key.readFields(din);
  return key;
 } catch (KeeperException.NoNodeException e) {
  LOG.error("No node in path [" + nodePath + "]");
 } catch (Exception ex) {
  throw new IOException(ex);
 }
 return null;
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
protected void updateToken(TokenIdent ident,
  DelegationTokenInformation tokenInfo) throws IOException {
 String nodeRemovePath =
   getNodePath(ZK_DTSM_TOKENS_ROOT, DELEGATION_TOKEN_PREFIX
     + ident.getSequenceNumber());
 try {
  if (zkClient.checkExists().forPath(nodeRemovePath) != null) {
   addOrUpdateToken(ident, tokenInfo, true);
  } else {
   addOrUpdateToken(ident, tokenInfo, false);
   LOG.debug("Attempted to update a non-existing znode " + nodeRemovePath);
  }
 } catch (Exception e) {
  throw new RuntimeException("Could not update Stored Token ZKDTSMDelegationToken_"
    + ident.getSequenceNumber(), e);
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
protected void removeStoredMasterKey(DelegationKey key) {
 String nodeRemovePath =
   getNodePath(ZK_DTSM_MASTER_KEY_ROOT,
     DELEGATION_KEY_PREFIX + key.getKeyId());
 if (LOG.isDebugEnabled()) {
  LOG.debug("Removing ZKDTSMDelegationKey_" + key.getKeyId());
 }
 try {
  if (zkClient.checkExists().forPath(nodeRemovePath) != null) {
   while(zkClient.checkExists().forPath(nodeRemovePath) != null){
    try {
     zkClient.delete().guaranteed().forPath(nodeRemovePath);
    } catch (NoNodeException nne) {
     // It is possible that the node might be deleted between the
     // check and the actual delete.. which might lead to an
     // exception that can bring down the daemon running this
     // SecretManager
     LOG.debug("Node already deleted by peer " + nodeRemovePath);
    }
   }
  } else {
   LOG.debug("Attempted to delete a non-existing znode " + nodeRemovePath);
  }
 } catch (Exception e) {
  LOG.debug(nodeRemovePath + " znode could not be removed!!");
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

private DelegationTokenInformation getTokenInfoFromZK(TokenIdent ident,
  boolean quiet) throws IOException {
 String nodePath =
   getNodePath(ZK_DTSM_TOKENS_ROOT,
     DELEGATION_TOKEN_PREFIX + ident.getSequenceNumber());
 try {

代码示例来源：origin: org.apache.hadoop/hadoop-common

private void addOrUpdateDelegationKey(DelegationKey key, boolean isUpdate)
  throws IOException {
 String nodeCreatePath =
   getNodePath(ZK_DTSM_MASTER_KEY_ROOT,
     DELEGATION_KEY_PREFIX + key.getKeyId());
 ByteArrayOutputStream os = new ByteArrayOutputStream();

代码示例来源：origin: org.apache.hadoop/hadoop-common

throws IOException {
String nodeRemovePath =
  getNodePath(ZK_DTSM_TOKENS_ROOT, DELEGATION_TOKEN_PREFIX
    + ident.getSequenceNumber());
if (LOG.isDebugEnabled()) {

代码示例来源：origin: org.apache.hadoop/hadoop-common

private void addOrUpdateToken(TokenIdent ident,
  DelegationTokenInformation info, boolean isUpdate) throws Exception {
 String nodeCreatePath =
   getNodePath(ZK_DTSM_TOKENS_ROOT, DELEGATION_TOKEN_PREFIX
     + ident.getSequenceNumber());
 try (ByteArrayOutputStream tokenOs = new ByteArrayOutputStream();
    DataOutputStream tokenOut = new DataOutputStream(tokenOs)) {
  ident.write(tokenOut);
  tokenOut.writeLong(info.getRenewDate());
  tokenOut.writeInt(info.getPassword().length);
  tokenOut.write(info.getPassword());
  if (LOG.isDebugEnabled()) {
   LOG.debug((isUpdate ? "Updating " : "Storing ")
     + "ZKDTSMDelegationToken_" +
     ident.getSequenceNumber());
  }
  if (isUpdate) {
   zkClient.setData().forPath(nodeCreatePath, tokenOs.toByteArray())
     .setVersion(-1);
  } else {
   zkClient.create().withMode(CreateMode.PERSISTENT)
     .forPath(nodeCreatePath, tokenOs.toByteArray());
  }
 }
}

代码示例来源：origin: io.hops/hadoop-common

private DelegationKey getKeyFromZK(int keyId) throws IOException {
 String nodePath =
   getNodePath(ZK_DTSM_MASTER_KEY_ROOT, DELEGATION_KEY_PREFIX + keyId);
 try {
  byte[] data = zkClient.getData().forPath(nodePath);
  if ((data == null) || (data.length == 0)) {
   return null;
  }
  ByteArrayInputStream bin = new ByteArrayInputStream(data);
  DataInputStream din = new DataInputStream(bin);
  DelegationKey key = new DelegationKey();
  key.readFields(din);
  return key;
 } catch (KeeperException.NoNodeException e) {
  LOG.error("No node in path [" + nodePath + "]");
 } catch (Exception ex) {
  throw new IOException(ex);
 }
 return null;
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

private DelegationKey getKeyFromZK(int keyId) throws IOException {
 String nodePath =
   getNodePath(ZK_DTSM_MASTER_KEY_ROOT, DELEGATION_KEY_PREFIX + keyId);
 try {
  byte[] data = zkClient.getData().forPath(nodePath);
  if ((data == null) || (data.length == 0)) {
   return null;
  }
  ByteArrayInputStream bin = new ByteArrayInputStream(data);
  DataInputStream din = new DataInputStream(bin);
  DelegationKey key = new DelegationKey();
  key.readFields(din);
  return key;
 } catch (KeeperException.NoNodeException e) {
  LOG.error("No node in path [" + nodePath + "]");
 } catch (Exception ex) {
  throw new IOException(ex);
 }
 return null;
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

private DelegationKey getKeyFromZK(int keyId) throws IOException {
 String nodePath =
   getNodePath(ZK_DTSM_MASTER_KEY_ROOT, DELEGATION_KEY_PREFIX + keyId);
 try {
  byte[] data = zkClient.getData().forPath(nodePath);
  if ((data == null) || (data.length == 0)) {
   return null;
  }
  ByteArrayInputStream bin = new ByteArrayInputStream(data);
  DataInputStream din = new DataInputStream(bin);
  DelegationKey key = new DelegationKey();
  key.readFields(din);
  return key;
 } catch (KeeperException.NoNodeException e) {
  LOG.error("No node in path [" + nodePath + "]");
 } catch (Exception ex) {
  throw new IOException(ex);
 }
 return null;
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

private DelegationKey getKeyFromZK(int keyId) throws IOException {
 String nodePath =
   getNodePath(ZK_DTSM_MASTER_KEY_ROOT, DELEGATION_KEY_PREFIX + keyId);
 try {
  byte[] data = zkClient.getData().forPath(nodePath);
  if ((data == null) || (data.length == 0)) {
   return null;
  }
  ByteArrayInputStream bin = new ByteArrayInputStream(data);
  DataInputStream din = new DataInputStream(bin);
  DelegationKey key = new DelegationKey();
  key.readFields(din);
  return key;
 } catch (KeeperException.NoNodeException e) {
  LOG.error("No node in path [" + nodePath + "]");
 } catch (Exception ex) {
  throw new IOException(ex);
 }
 return null;
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

@Override
protected void removeStoredMasterKey(DelegationKey key) {
 String nodeRemovePath =
   getNodePath(ZK_DTSM_MASTER_KEY_ROOT,
     DELEGATION_KEY_PREFIX + key.getKeyId());
 if (LOG.isDebugEnabled()) {
  LOG.debug("Removing ZKDTSMDelegationKey_" + key.getKeyId());
 }
 try {
  if (zkClient.checkExists().forPath(nodeRemovePath) != null) {
   while(zkClient.checkExists().forPath(nodeRemovePath) != null){
    zkClient.delete().guaranteed().forPath(nodeRemovePath);
   }
  } else {
   LOG.debug("Attempted to delete a non-existing znode " + nodeRemovePath);
  }
 } catch (Exception e) {
  LOG.debug(nodeRemovePath + " znode could not be removed!!");
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

@Override
protected void removeStoredMasterKey(DelegationKey key) {
 String nodeRemovePath =
   getNodePath(ZK_DTSM_MASTER_KEY_ROOT,
     DELEGATION_KEY_PREFIX + key.getKeyId());
 if (LOG.isDebugEnabled()) {
  LOG.debug("Removing ZKDTSMDelegationKey_" + key.getKeyId());
 }
 try {
  if (zkClient.checkExists().forPath(nodeRemovePath) != null) {
   while(zkClient.checkExists().forPath(nodeRemovePath) != null){
    zkClient.delete().guaranteed().forPath(nodeRemovePath);
   }
  } else {
   LOG.debug("Attempted to delete a non-existing znode " + nodeRemovePath);
  }
 } catch (Exception e) {
  LOG.debug(nodeRemovePath + " znode could not be removed!!");
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

@Override
protected void updateToken(TokenIdent ident,
  DelegationTokenInformation tokenInfo) throws IOException {
 String nodeRemovePath =
   getNodePath(ZK_DTSM_TOKENS_ROOT, DELEGATION_TOKEN_PREFIX
     + ident.getSequenceNumber());
 try {
  if (zkClient.checkExists().forPath(nodeRemovePath) != null) {
   addOrUpdateToken(ident, tokenInfo, true);
  } else {
   addOrUpdateToken(ident, tokenInfo, false);
   LOG.debug("Attempted to update a non-existing znode " + nodeRemovePath);
  }
 } catch (Exception e) {
  throw new RuntimeException("Could not update Stored Token ZKDTSMDelegationToken_"
    + ident.getSequenceNumber(), e);
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

@Override
protected void updateToken(TokenIdent ident,
  DelegationTokenInformation tokenInfo) throws IOException {
 String nodeRemovePath =
   getNodePath(ZK_DTSM_TOKENS_ROOT, DELEGATION_TOKEN_PREFIX
     + ident.getSequenceNumber());
 try {
  if (zkClient.checkExists().forPath(nodeRemovePath) != null) {
   addOrUpdateToken(ident, tokenInfo, true);
  } else {
   addOrUpdateToken(ident, tokenInfo, false);
   LOG.debug("Attempted to update a non-existing znode " + nodeRemovePath);
  }
 } catch (Exception e) {
  throw new RuntimeException("Could not update Stored Token ZKDTSMDelegationToken_"
    + ident.getSequenceNumber(), e);
 }
}

代码示例来源：origin: io.hops/hadoop-common

@Override
protected void updateToken(TokenIdent ident,
  DelegationTokenInformation tokenInfo) throws IOException {
 String nodeRemovePath =
   getNodePath(ZK_DTSM_TOKENS_ROOT, DELEGATION_TOKEN_PREFIX
     + ident.getSequenceNumber());
 try {
  if (zkClient.checkExists().forPath(nodeRemovePath) != null) {
   addOrUpdateToken(ident, tokenInfo, true);
  } else {
   addOrUpdateToken(ident, tokenInfo, false);
   LOG.debug("Attempted to update a non-existing znode " + nodeRemovePath);
  }
 } catch (Exception e) {
  throw new RuntimeException("Could not update Stored Token ZKDTSMDelegationToken_"
    + ident.getSequenceNumber(), e);
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

@Override
protected void removeStoredToken(TokenIdent ident)
  throws IOException {
 String nodeRemovePath =
   getNodePath(ZK_DTSM_TOKENS_ROOT, DELEGATION_TOKEN_PREFIX
     + ident.getSequenceNumber());
 if (LOG.isDebugEnabled()) {
  LOG.debug("Removing ZKDTSMDelegationToken_"
    + ident.getSequenceNumber());
 }
 try {
  if (zkClient.checkExists().forPath(nodeRemovePath) != null) {
   while(zkClient.checkExists().forPath(nodeRemovePath) != null){
    zkClient.delete().guaranteed().forPath(nodeRemovePath);
   }
  } else {
   LOG.debug("Attempted to remove a non-existing znode " + nodeRemovePath);
  }
 } catch (Exception e) {
  throw new RuntimeException(
    "Could not remove Stored Token ZKDTSMDelegationToken_"
    + ident.getSequenceNumber(), e);
 }
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

@Override
protected void updateToken(TokenIdent ident,
  DelegationTokenInformation tokenInfo) throws IOException {
 String nodeRemovePath =
   getNodePath(ZK_DTSM_TOKENS_ROOT, DELEGATION_TOKEN_PREFIX
     + ident.getSequenceNumber());
 try {
  if (zkClient.checkExists().forPath(nodeRemovePath) != null) {
   addOrUpdateToken(ident, tokenInfo, true);
  } else {
   addOrUpdateToken(ident, tokenInfo, false);
   LOG.debug("Attempted to update a non-existing znode " + nodeRemovePath);
  }
 } catch (Exception e) {
  throw new RuntimeException("Could not update Stored Token ZKDTSMDelegationToken_"
    + ident.getSequenceNumber(), e);
 }
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

@Override
protected void removeStoredToken(TokenIdent ident)
  throws IOException {
 String nodeRemovePath =
   getNodePath(ZK_DTSM_TOKENS_ROOT, DELEGATION_TOKEN_PREFIX
     + ident.getSequenceNumber());
 if (LOG.isDebugEnabled()) {
  LOG.debug("Removing ZKDTSMDelegationToken_"
    + ident.getSequenceNumber());
 }
 try {
  if (zkClient.checkExists().forPath(nodeRemovePath) != null) {
   while(zkClient.checkExists().forPath(nodeRemovePath) != null){
    zkClient.delete().guaranteed().forPath(nodeRemovePath);
   }
  } else {
   LOG.debug("Attempted to remove a non-existing znode " + nodeRemovePath);
  }
 } catch (Exception e) {
  throw new RuntimeException(
    "Could not remove Stored Token ZKDTSMDelegationToken_"
    + ident.getSequenceNumber(), e);
 }
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

@Override
protected void removeStoredMasterKey(DelegationKey key) {
 String nodeRemovePath =
   getNodePath(ZK_DTSM_MASTER_KEY_ROOT,
     DELEGATION_KEY_PREFIX + key.getKeyId());
 if (LOG.isDebugEnabled()) {
  LOG.debug("Removing ZKDTSMDelegationKey_" + key.getKeyId());
 }
 try {
  if (zkClient.checkExists().forPath(nodeRemovePath) != null) {
   while(zkClient.checkExists().forPath(nodeRemovePath) != null){
    zkClient.delete().guaranteed().forPath(nodeRemovePath);
   }
  } else {
   LOG.debug("Attempted to delete a non-existing znode " + nodeRemovePath);
  }
 } catch (Exception e) {
  LOG.debug(nodeRemovePath + " znode could not be removed!!");
 }
}

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

ZKDelegationTokenSecretManager

相关文章

    查看更多

    热门标签

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

    最新文章

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