本文整理了Java中org.apache.hive.service.server.HiveServer2.setUpZooKeeperAuth()
方法的一些代码示例,展示了HiveServer2.setUpZooKeeperAuth()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。HiveServer2.setUpZooKeeperAuth()
方法的具体详情如下:
包路径:org.apache.hive.service.server.HiveServer2
类名称: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,
内容来源于网络,如有侵权,请联系作者删除!