org.apache.hive.service.server.HiveServer2.setUpZooKeeperAuth()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(1.5k)|赞(0)|评价(0)|浏览(144)

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

HiveServer2.setUpZooKeeperAuth介绍

[英]For a kerberized cluster, we dynamically set up the client's JAAS conf.
[中]对于kerberized集群,我们动态地设置客户机的JAAS conf。

代码示例

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

setUpZooKeeperAuth(hiveConf);
zKClientForPrivSync = hiveConf.getZKConfig().startZookeeperClient(zooKeeperAclProvider, true);
String rootNamespace = hiveConf.getVar(HiveConf.ConfVars.HIVE_SERVER2_ZOOKEEPER_NAMESPACE);

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

private CuratorFramework startZookeeperClient(HiveConf hiveConf) throws Exception {
 setUpZooKeeperAuth(hiveConf);
 String zooKeeperEnsemble = ZooKeeperHiveHelper.getQuorumServers(hiveConf);
 int sessionTimeout =

代码示例来源:origin: org.spark-project.hive/hive-service

String instanceURI = getServerInstanceURI(hiveConf);
byte[] znodeDataUTF8 = instanceURI.getBytes(Charset.forName("UTF-8"));
setUpZooKeeperAuth(hiveConf);
int sessionTimeout =
  (int) hiveConf.getTimeVar(HiveConf.ConfVars.HIVE_ZOOKEEPER_SESSION_TIMEOUT,

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

String instanceURI = getServerInstanceURI(hiveConf);
byte[] znodeDataUTF8 = instanceURI.getBytes(Charset.forName("UTF-8"));
setUpZooKeeperAuth(hiveConf);
int sessionTimeout =
  (int) hiveConf.getTimeVar(HiveConf.ConfVars.HIVE_ZOOKEEPER_SESSION_TIMEOUT,

相关文章