本文整理汇总了Java中org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient类的典型用法代码示例。如果您正苦于以下问题:Java ZookeeperClient类的具体用法?Java ZookeeperClient怎么用?Java ZookeeperClient使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ZookeeperClient类属于org.trustedanalytics.cfbroker.store.zookeeper.service包,在下文中一共展示了ZookeeperClient类的14个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: getZKClient
import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
@Bean(initMethod = "init", destroyMethod = "destroy")
@Profile(Profiles.CLOUD)
@Qualifier(Qualifiers.BROKER_INSTANCE)
public ZookeeperClient getZKClient() throws IOException, LoginException {
if (kerberosProperties.isKerberosEnabled()) {
LOGGER.info("Found kerberos configuration - trying to authenticate");
KrbLoginManager loginManager =
KrbLoginManagerFactory.getInstance().getKrbLoginManagerInstance(
kerberosProperties.getKdc(), kerberosProperties.getRealm());
loginManager.loginWithCredentials(config.getUser(), config.getPassword().toCharArray());
} else {
LOGGER.warn("kerberos configuration empty or invalid - will not try to authenticate.");
}
return new ZookeeperClientBuilder(config.getZkClusterHosts(), config.getUser(),
config.getBrokerRootNode(), config.getBrokerRootNode()).build();
}
开发者ID:trustedanalytics,项目名称:zookeeper-broker,代码行数:18,代码来源:ZookeeperConfiguration.java
示例2: getZkClient
import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
@Bean(initMethod = "init", destroyMethod = "destroy")
@Qualifier(Qualifiers.BROKER_STORE)
@Profile("integration-test")
public ZookeeperClient getZkClient(TestingServer zkServer) throws IOException {
return new ZookeeperClientBuilder(zkServer.getConnectString(), user, password, brokerStoreNode)
.build();
}
开发者ID:trustedanalytics,项目名称:hive-broker,代码行数:8,代码来源:ZkLocalConfiguration.java
示例3: testZookeeperClientWithoutRootCreation
import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
private void testZookeeperClientWithoutRootCreation() throws Exception {
ZookeeperClient zkClient =
new ZookeeperClientBuilder(connectionString, USERNAME, PASSWORD, ROOT_DIR).build();
zkClient.init();
zkClient.exists(ROOT_DIR);
zkClient.destroy();
}
开发者ID:trustedanalytics,项目名称:broker-store,代码行数:8,代码来源:ZookeeperClientBuilderTest.java
示例4: testZookeeperClientWithRootCreation
import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
private void testZookeeperClientWithRootCreation() throws Exception {
String digest =
DigestAuthenticationProvider.generateDigest(String.format("%s:%s", USERNAME, PASSWORD));
List<ACL> acl = Arrays.asList(new ACL(ZooDefs.Perms.ALL, new Id("digest", digest)));
ZookeeperClient zkClient =
new ZookeeperClientBuilder(connectionString, USERNAME, PASSWORD, ROOT_DIR)
.withRootCreation(acl).build();
zkClient.init();
zkClient.exists(ROOT_DIR);
zkClient.destroy();
}
开发者ID:trustedanalytics,项目名称:broker-store,代码行数:13,代码来源:ZookeeperClientBuilderTest.java
示例5: getZookeeperClient
import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
private ZookeeperClient getZookeeperClient(String node) throws Exception {
String absoluteNode = zkBaseNode + node;
createIfNotExist(zkUri, absoluteNode);
ZookeeperClient zkClient =
new ZookeeperClientBuilder(zkUri, zkUser, zkPass, absoluteNode).build();
zkClient.init();
return zkClient;
}
开发者ID:trustedanalytics,项目名称:h2o-broker,代码行数:9,代码来源:ZookeeperConfig.java
示例6: getZkClient
import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
@Bean(initMethod = "init", destroyMethod = "destroy")
@Qualifier(Qualifiers.BROKER_STORE)
@Profile("integration-test")
public ZookeeperClient getZkClient(TestingServer zkServer) throws IOException {
ZookeeperClient client =
new ZookeeperClientBuilder(zkServer.getConnectString(), user, password, brokerStoreNode).build();
return client;
}
开发者ID:trustedanalytics,项目名称:hdfs-broker,代码行数:9,代码来源:ZkLocalConfiguration.java
示例7: getZkClient
import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
@Bean(initMethod = "init", destroyMethod = "destroy")
@Qualifier(Qualifiers.BROKER_STORE)
@Profile("integration-test")
public ZookeeperClient getZkClient() throws Exception {
String zkClusterHosts = "localhost:" + utility.getZkCluster().getClientPort();
ZooKeeperCredentials credendials =
new ZooKeeperCredentials(zkClusterHosts, user, password);
ZooKeeperTestOperations.createSecuredNode(credendials, brokerStoreNode);
ZookeeperClient client =
new ZookeeperClientBuilder(zkClusterHosts, user, password, brokerStoreNode)
.build();
return client;
}
开发者ID:trustedanalytics,项目名称:hbase-broker,代码行数:14,代码来源:ZkLocalConfiguration.java
示例8: getZkClient
import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
@Bean(initMethod = "init", destroyMethod = "destroy")
@Qualifier(org.trustedanalytics.servicebroker.framework.Qualifiers.BROKER_STORE)
@Profile("integration-test")
public ZookeeperClient getZkClient(TestingServer zkServer) throws IOException {
ZookeeperClient client =
new ZookeeperClientBuilder(zkServer.getConnectString(), user, password, brokerStoreNode)
.build();
return client;
}
开发者ID:trustedanalytics,项目名称:zookeeper-broker,代码行数:10,代码来源:ZkLocalConfiguration.java
示例9: getInstanceZkClient
import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
@Bean(initMethod = "init", destroyMethod = "destroy")
@Qualifier(Qualifiers.BROKER_INSTANCE)
@Profile("integration-test")
public ZookeeperClient getInstanceZkClient(TestingServer zkServer) throws IOException {
ZookeeperClient client =
new ZookeeperClientBuilder(zkServer.getConnectString(), user, password, brokerRootNode)
.build();
return client;
}
开发者ID:trustedanalytics,项目名称:zookeeper-broker,代码行数:10,代码来源:ZkLocalConfiguration.java
示例10: brokerZKClient
import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
@Bean
public ZookeeperClient brokerZKClient() throws Exception {
LOGGER.info("Creating zkClient with zkUri='{}' zkNode='{}'", zkUri, zkBrokerNode);
return getZookeeperClient(zkBrokerNode);
}
开发者ID:trustedanalytics,项目名称:h2o-broker,代码行数:6,代码来源:ZookeeperConfig.java
示例11: credentialsZKClient
import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
@Bean
public ZookeeperClient credentialsZKClient() throws Exception {
LOGGER.info("Creating zkClient with zkUri='{}' zkNode='{}'", zkUri, zkCredentialsNode);
return getZookeeperClient(zkCredentialsNode);
}
开发者ID:trustedanalytics,项目名称:h2o-broker,代码行数:6,代码来源:ZookeeperConfig.java
示例12: brokerZKClient
import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
@Bean(initMethod = "init", destroyMethod = "destroy")
public ZookeeperClient brokerZKClient() throws Exception {
return getZookeeperClient(zkServer.getConnectString(), config.getZookeeperMetadataNode());
}
开发者ID:trustedanalytics,项目名称:h2o-broker,代码行数:5,代码来源:TestConfig.java
示例13: credentialsZKClient
import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
@Bean(initMethod = "init", destroyMethod = "destroy")
public ZookeeperClient credentialsZKClient() throws Exception {
return getZookeeperClient(zkServer.getConnectString(), config.getZookeeperCredentialsNode());
}
开发者ID:trustedanalytics,项目名称:h2o-broker,代码行数:5,代码来源:TestConfig.java
示例14: getZookeeperClient
import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
private ZookeeperClient getZookeeperClient(String connectionString, String rootNode)
throws IOException {
return new ZookeeperClientBuilder(connectionString, "user", "password", rootNode).build();
}
开发者ID:trustedanalytics,项目名称:h2o-broker,代码行数:5,代码来源:TestConfig.java
注:本文中的org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论