gpt4 book ai didi

com.liveramp.hank.coordinator.zk.ZooKeeperCoordinator.()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-13 12:23:41 27 4
gpt4 key购买 nike

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

ZooKeeperCoordinator.<init>介绍

[英]Blocks until the connection to the ZooKeeper service has been established. See ZooKeeperConnection#ZooKeeperConnection(String,int)

Package-private constructor that is mainly used for testing. The last boolean flag allows you to prevent the ZooKeeperCoordinator from immediately trying to cache all the configuration information from the ZooKeeper service, which is useful if you don't want to have to setup your entire configuration just to run a few simple tests.
[中]阻塞,直到与ZooKeeper服务建立连接。请参见ZookePerconnection#ZookePerconnection(字符串,int)
包私有构造函数,主要用于测试。最后一个布尔标志允许您防止ZooKeepOrdinator立即尝试缓存ZooKeeper服务中的所有配置信息,如果您不想为了运行几个简单的测试而必须设置整个配置,这一点很有用。

代码示例

代码示例来源:origin: LiveRamp/hank

@Override
public Coordinator getCoordinator(Map<String, Object> options) {
 LOG.info("Creating Coordinator with options: "+options);
 validateOptions(options);
 try {
  //  TODO temporary until clean upusages
  if(options.containsKey(MAX_CONNECTION_ATTEMPTS_KEY)) {
   return new ZooKeeperCoordinator(
     (String)options.get(CONNECT_STRING_KEY),
     (Integer)options.get(SESSION_TIMEOUT_KEY),
     (String)options.get(DOMAINS_ROOT_KEY),
     (String)options.get(DOMAIN_GROUPS_ROOT_KEY),
     (String)options.get(RING_GROUPS_ROOT_KEY),
     (Integer)options.get(MAX_CONNECTION_ATTEMPTS_KEY));
  }else{
   return new ZooKeeperCoordinator(
     (String)options.get(CONNECT_STRING_KEY),
     (Integer)options.get(SESSION_TIMEOUT_KEY),
     (String)options.get(DOMAINS_ROOT_KEY),
     (String)options.get(DOMAIN_GROUPS_ROOT_KEY),
     (String)options.get(RING_GROUPS_ROOT_KEY));
  }
 } catch (Exception e) {
  throw new RuntimeException("Couldn't make a ZooKeeperCoordinator from options "
    + options, e);
 }
}

代码示例来源:origin: LiveRamp/hank

private ZooKeeperCoordinator getCoord() throws Exception {
 return new ZooKeeperCoordinator(getZkConnectString(), 100000000, domains_root, domain_groups_root, ring_groups_root, 5);
}

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com