gpt4 book ai didi

org.apache.accumulo.core.client.ZooKeeperInstance.getZooKeepers()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-17 00:30:40 25 4
gpt4 key购买 nike

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

ZooKeeperInstance.getZooKeepers介绍

暂无

代码示例

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

@Override
 public String toString() {
  StringBuilder sb = new StringBuilder(64);
  sb.append("ZooKeeperInstance: ").append(getInstanceName()).append(" ").append(getZooKeepers());
  return sb.toString();
 }
}

代码示例来源:origin: org.apache.accumulo/accumulo-test

private void waitForGCLock(Connector conn) throws InterruptedException {
 // Check if the GC process has the lock before wasting our retry attempts
 ZooKeeperInstance zki = (ZooKeeperInstance) conn.getInstance();
 ZooCacheFactory zcf = new ZooCacheFactory();
 ZooCache zcache = zcf.getZooCache(zki.getZooKeepers(), zki.getZooKeepersSessionTimeOut());
 String zkPath = ZooUtil.getRoot(conn.getInstance()) + Constants.ZGC_LOCK;
 log.info("Looking for GC lock at {}", zkPath);
 byte[] data = ZooLock.getLockData(zcache, zkPath, null);
 while (null == data) {
  log.info("Waiting for GC ZooKeeper lock to be acquired");
  Thread.sleep(1000);
  data = ZooLock.getLockData(zcache, zkPath, null);
 }
}

代码示例来源:origin: org.apache.accumulo/accumulo-core

@Override
 public String toString() {
  StringBuilder sb = new StringBuilder(64);
  sb.append("ZooKeeperInstance: ").append(getInstanceName()).append(" ").append(getZooKeepers());
  return sb.toString();
 }
}

代码示例来源:origin: NationalSecurityAgency/datawave

ZooKeeperInstance instance = new ZooKeeperInstance(zkConfig);
Map<String,String> confMap = new HashMap<>();
confMap.put(DistributedTrace.TRACER_ZK_HOST, instance.getZooKeepers());
confMap.put(DistributedTrace.TRACER_ZK_PATH, ZooUtil.getRoot(instance) + Constants.ZTRACERS);
confMap.put(DistributedTrace.TRACE_HOST_PROPERTY, InetAddress.getLocalHost().getHostName());

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