org.apache.hadoop.util.ZKUtil.parseAuth()方法的使用及代码示例

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

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

ZKUtil.parseAuth介绍

[英]Parse a comma-separated list of authentication mechanisms. Each such mechanism should be of the form 'scheme:auth' -- the same syntax used for the 'addAuth' command in the ZK CLI.
[中]解析以逗号分隔的身份验证机制列表。每个这样的机制的形式都应该是“scheme:auth”——与ZK CLI中的“addAuth”命令使用的语法相同。

代码示例

代码示例来源：origin: apache/kylin

  1. public static List<ZKUtil.ZKAuthInfo> getZKAuths() throws Exception {
  2.   // Parse Auths from configuration.
  3.   String zkAuthConf = KylinConfig.getInstanceFromEnv().getZKAuths();
  4.   try {
  5.     zkAuthConf = ZKUtil.resolveConfIndirection(zkAuthConf);
  6.     if (zkAuthConf != null) {
  7.       return ZKUtil.parseAuth(zkAuthConf);
  8.     } else {
  9.       return Collections.emptyList();
  10.     }
  11.   } catch (Exception e) {
  12.     logger.error("Couldn't read Auth based on 'kylin.env.zookeeper.zk-auth' in kylin.properties");
  13.     throw e;
  14.   }
  15. }

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

  1. /**
  2.   * Utility method to fetch ZK auth info from the configuration.
  3.   * @throws java.io.IOException if the Zookeeper ACLs configuration file
  4.   * cannot be read
  5.   * @throws ZKUtil.BadAuthFormatException if the auth format is invalid
  6.   */
  7.  public static List<ZKUtil.ZKAuthInfo> getZKAuthInfos(Configuration conf,
  8.    String configKey) throws IOException {
  9.   char[] zkAuthChars = conf.getPassword(configKey);
  10.   String zkAuthConf =
  11.     zkAuthChars != null ? String.valueOf(zkAuthChars) : null;
  12.   try {
  13.    zkAuthConf = ZKUtil.resolveConfIndirection(zkAuthConf);
  14.    if (zkAuthConf != null) {
  15.     return ZKUtil.parseAuth(zkAuthConf);
  16.    } else {
  17.     return Collections.emptyList();
  18.    }
  19.   } catch (IOException | ZKUtil.BadAuthFormatException e) {
  20.    LOG.error("Couldn't read Auth based on {}", configKey);
  21.    throw e;
  22.   }
  23.  }
  24. }

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

  1. /**
  2.   * Utility method to fetch ZK auth info from the configuration
  3.   */
  4.  public static List<ZKUtil.ZKAuthInfo> getZKAuths(Configuration conf)
  5.    throws Exception {
  6.   String zkAuthConf = conf.get(YarnConfiguration.RM_ZK_AUTH);
  7.   try {
  8.    zkAuthConf = ZKUtil.resolveConfIndirection(zkAuthConf);
  9.    if (zkAuthConf != null) {
  10.     return ZKUtil.parseAuth(zkAuthConf);
  11.    } else {
  12.     return Collections.emptyList();
  13.    }
  14.   } catch (Exception e) {
  15.    LOG.error("Couldn't read Auth based on " + YarnConfiguration.RM_ZK_AUTH);
  16.    throw e;
  17.   }
  18.  }
  19. }

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

  1. /**
  2.   * Utility method to fetch ZK auth info from the configuration
  3.   */
  4.  public static List<ZKUtil.ZKAuthInfo> getZKAuths(Configuration conf)
  5.    throws Exception {
  6.   String zkAuthConf = conf.get(YarnConfiguration.RM_ZK_AUTH);
  7.   try {
  8.    zkAuthConf = ZKUtil.resolveConfIndirection(zkAuthConf);
  9.    if (zkAuthConf != null) {
  10.     return ZKUtil.parseAuth(zkAuthConf);
  11.    } else {
  12.     return Collections.emptyList();
  13.    }
  14.   } catch (Exception e) {
  15.    LOG.error("Couldn't read Auth based on " + YarnConfiguration.RM_ZK_AUTH);
  16.    throw e;
  17.   }
  18.  }
  19. }

代码示例来源：origin: com.cloudera.llama/llama

  1. public List<ZKUtil.ZKAuthInfo> getZkAuths() throws LlamaException {
  2.   String zkAuthConf = conf.get(ZK_AUTH);
  3.   try {
  4.    zkAuthConf = ZKUtil.resolveConfIndirection(zkAuthConf);
  5.    if (zkAuthConf != null) {
  6.     return ZKUtil.parseAuth(zkAuthConf);
  7.    } else {
  8.     return Collections.emptyList();
  9.    }
  10.   } catch (Exception e) {
  11.    throw new LlamaException(e, ErrorCode.ILLEGAL_ARGUMENT,
  12.      "Couldn't read Auth based on ", ZK_AUTH);
  13.   }
  14.  }
  15. }

代码示例来源：origin: org.apache.kylin/kylin-storage-hbase

  1. public static List<ZKUtil.ZKAuthInfo> getZKAuths() throws Exception {
  2.   // Parse Auths from configuration.
  3.   String zkAuthConf = KylinConfig.getInstanceFromEnv().getZKAuths();
  4.   try {
  5.     zkAuthConf = ZKUtil.resolveConfIndirection(zkAuthConf);
  6.     if (zkAuthConf != null) {
  7.       return ZKUtil.parseAuth(zkAuthConf);
  8.     } else {
  9.       return Collections.emptyList();
  10.     }
  11.   } catch (Exception e) {
  12.     logger.error("Couldn't read Auth based on 'kylin.env.zookeeper.zk-auth' in kylin.properties");
  13.     throw e;
  14.   }
  15. }

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

  1. List<ZKAuthInfo> zkAuths;
  2. if (zkAuthConf != null) {
  3.  zkAuths = ZKUtil.parseAuth(zkAuthConf);
  4. } else {
  5.  zkAuths = Collections.emptyList();

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

  1. List<ZKAuthInfo> zkAuths;
  2. if (zkAuthConf != null) {
  3.  zkAuths = ZKUtil.parseAuth(zkAuthConf);
  4. } else {
  5.  zkAuths = Collections.emptyList();

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

  1. List<ZKAuthInfo> zkAuths;
  2. if (zkAuthConf != null) {
  3.  zkAuths = ZKUtil.parseAuth(zkAuthConf);
  4. } else {
  5.  zkAuths = Collections.emptyList();

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

  1. @Test
  2. public void testEmptyAuth() {
  3.  List<ZKAuthInfo> result = ZKUtil.parseAuth("");
  4.  assertTrue(result.isEmpty());
  5. }

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

  1. @Test
  2. public void testNullAuth() {
  3.  List<ZKAuthInfo> result = ZKUtil.parseAuth(null);
  4.  assertTrue(result.isEmpty());
  5. }

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

  1. @Test
  2. public void testNullAuth() {
  3.  List<ZKAuthInfo> result = ZKUtil.parseAuth(null);
  4.  assertTrue(result.isEmpty());
  5. }

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

  1. @Test
  2. public void testEmptyAuth() {
  3.  List<ZKAuthInfo> result = ZKUtil.parseAuth("");
  4.  assertTrue(result.isEmpty());
  5. }

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

  1. List<ZKAuthInfo> zkAuths;
  2. if (zkAuthConf != null) {
  3.  zkAuths = ZKUtil.parseAuth(zkAuthConf);
  4. } else {
  5.  zkAuths = Collections.emptyList();

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

  1. @Test
  2. public void testGoodAuths() {
  3.  List<ZKAuthInfo> result = ZKUtil.parseAuth(
  4.    "scheme:data,\n   scheme2:user:pass");
  5.  assertEquals(2, result.size());
  6.  ZKAuthInfo auth0 = result.get(0);
  7.  assertEquals("scheme", auth0.getScheme());
  8.  assertEquals("data", new String(auth0.getAuth()));
  9.  
  10.  ZKAuthInfo auth1 = result.get(1);
  11.  assertEquals("scheme2", auth1.getScheme());
  12.  assertEquals("user:pass", new String(auth1.getAuth()));
  13. }

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

  1. @Test
  2. public void testGoodAuths() {
  3.  List<ZKAuthInfo> result = ZKUtil.parseAuth(
  4.    "scheme:data,\n   scheme2:user:pass");
  5.  assertEquals(2, result.size());
  6.  ZKAuthInfo auth0 = result.get(0);
  7.  assertEquals("scheme", auth0.getScheme());
  8.  assertEquals("data", new String(auth0.getAuth()));
  9.  
  10.  ZKAuthInfo auth1 = result.get(1);
  11.  assertEquals("scheme2", auth1.getScheme());
  12.  assertEquals("user:pass", new String(auth1.getAuth()));
  13. }

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

ZKUtil

相关文章

    查看更多

    热门标签

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

    最新文章

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