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

ZooKeeperClientBuilder.build介绍

[英]Build a zookeeper client.
[中]建立一个zookeeper客户端。

代码示例

代码示例来源：origin: twitter/distributedlog

private ZooKeeperClient buildClient() throws Exception {
  return clientBuilder().zkAclId(null).build();
}

代码示例来源：origin: twitter/distributedlog

private ZooKeeperClient buildAuthdClient(String id) throws Exception {
  return clientBuilder().zkAclId(id).build();
}

代码示例来源：origin: twitter/distributedlog

@Test(timeout = 60000)
public void testAclPermsZkAccessNoConflict() throws Exception {
  String namespace = "/" + runtime.getMethodName();
  initDlogMeta(namespace, "test-un", "test-stream");
  URI uri = createDLMURI(namespace);
  ZooKeeperClient zkc = TestZooKeeperClientBuilder.newBuilder()
    .name("unpriv")
    .uri(uri)
    .build();
  zkc.get().getChildren(uri.getPath() + "/test-stream", false, new Stat());
  zkc.get().getData(uri.getPath() + "/test-stream", false, new Stat());
}

代码示例来源：origin: twitter/distributedlog

@Before
public void setup() throws Exception {
  zkc = TestZooKeeperClientBuilder.newBuilder()
      .zkServers(zkServers)
      .build();
}

代码示例来源：origin: twitter/distributedlog

static interface ZooKeeperClientHandler<T> {
  T handle(ZooKeeperClient zkc) throws IOException;
}

代码示例来源：origin: twitter/distributedlog

@Before
public void setup() throws Exception {
  executorService = Executors.newSingleThreadScheduledExecutor();
  zkc = TestZooKeeperClientBuilder.newBuilder()
      .uri(createURI("/"))
      .build();
  conf = new DistributedLogConfiguration();
}

代码示例来源：origin: twitter/distributedlog

@Before
public void setup() throws Exception {
  zooKeeperClient =
    TestZooKeeperClientBuilder.newBuilder()
      .uri(createDLMURI("/"))
      .build();
}

代码示例来源：origin: twitter/distributedlog

@Before
public void setup() throws Exception {
  zkc = TestZooKeeperClientBuilder.newBuilder()
      .uri(createURI("/"))
      .build();
}

代码示例来源：origin: twitter/distributedlog

@Before
public void setup() throws Exception {
  zkc = TestZooKeeperClientBuilder
    .newBuilder()
    .uri(createDLMURI("/"))
    .build();
}

代码示例来源：origin: twitter/distributedlog

@Before
public void setup() throws Exception {
  zooKeeperClient = TestZooKeeperClientBuilder
    .newBuilder()
    .uri(createDLMURI("/"))
    .build();
  conf.setTraceReadAheadMetadataChanges(true);
}

代码示例来源：origin: twitter/distributedlog

@Before
public void setup() throws Exception {
  zkc = TestZooKeeperClientBuilder.newBuilder()
      .uri(createURI("/"))
      .sessionTimeoutMs(10000)
      .build();
  resolver = new ZkMetadataResolver(zkc);
}

代码示例来源：origin: twitter/distributedlog

@Before
public void setup() throws Exception {
  zkc = TestZooKeeperClientBuilder.newBuilder()
      .name("zkc")
      .uri(DLMTestUtil.createDLMURI(zkPort, "/"))
      .sessionTimeoutMs(sessionTimeoutMs)
      .build();
}

代码示例来源：origin: twitter/distributedlog

@Before
public void setup() throws Exception {
  zkc = TestZooKeeperClientBuilder.newBuilder()
      .name("zkc")
      .uri(DLMTestUtil.createDLMURI(zkPort, "/"))
      .sessionTimeoutMs(sessionTimeoutMs)
      .build();
}

代码示例来源：origin: twitter/distributedlog

@Before
public void setup() throws Exception {
  zkc = TestZooKeeperClientBuilder.newBuilder()
      .uri(createURI("/"))
      .build();
  bkc = BookKeeperClientBuilder.newBuilder().name("bkc")
      .dlConfig(dlConf).ledgersPath(ledgersPath).zkc(zkc).build();
  allocationExecutor = Executors.newSingleThreadScheduledExecutor();
}

代码示例来源：origin: twitter/distributedlog

@Before
public void setup() throws Exception {
  zkc = TestZooKeeperClientBuilder.newBuilder()
      .zkServers(zkServers)
      .build();
  bkc = BookKeeperClientBuilder.newBuilder()
      .name("bkc")
      .zkc(zkc)
      .ledgersPath(ledgersPath)
      .dlConfig(conf)
      .build();
}

代码示例来源：origin: twitter/distributedlog

@Before
public void setup() throws Exception {
  zkc = TestZooKeeperClientBuilder.newBuilder()
      .uri(createDLMURI("/"))
      .sessionTimeoutMs(zkSessionTimeoutMs)
      .build();
  scheduler = OrderedScheduler.newBuilder()
      .name("test-zk-namespace-watcher")
      .corePoolSize(1)
      .build();
}

代码示例来源：origin: twitter/distributedlog

@Test(timeout = 60000)
public void testZooKeeperReconnection() throws Exception {
  int sessionTimeoutMs = 100;
  ZooKeeperClient zkc = clientBuilder(sessionTimeoutMs).zkAclId(null).build();
  ZooKeeper zk = zkc.get();
  long sessionId = zk.getSessionId();
  ZooKeeperClientUtils.expireSession(zkc, zkServers, 2 * sessionTimeoutMs);
  ZooKeeper newZk = zkc.get();
  while (!ZooKeeper.States.CONNECTED.equals(newZk.getState())) {
    TimeUnit.MILLISECONDS.sleep(sessionTimeoutMs / 2);
  }
  long newSessionId = newZk.getSessionId();
  assertTrue(newZk == zk);
  assertFalse(sessionId == newSessionId);
}

代码示例来源：origin: twitter/distributedlog

@Before
public void setup() throws Exception {
  scheduler = OrderedScheduler.newBuilder()
      .name("test-logsegment-metadata-store-updater")
      .corePoolSize(1)
      .build();
  zkc = TestZooKeeperClientBuilder.newBuilder()
      .uri(createURI("/"))
      .sessionTimeoutMs(10000)
      .build();
  metadataStore = new ZKLogSegmentMetadataStore(conf, zkc, scheduler);
}

代码示例来源：origin: twitter/distributedlog

@Before
public void setup() throws Exception {
  zkc = TestZooKeeperClientBuilder.newBuilder()
      .uri(createURI("/"))
      .zkServers(zkServers)
      .build();
  bkc = BookKeeperClientBuilder.newBuilder().name("bkc")
      .dlConfig(dlConf).ledgersPath(ledgersPath).zkc(zkc).build();
}

代码示例来源：origin: twitter/distributedlog

@Before
public void setup() throws Exception {
  zkc = TestZooKeeperClientBuilder.newBuilder()
      .uri(createDLMURI("/"))
      .sessionTimeoutMs(zkSessionTimeoutMs)
      .build();
  scheduler = OrderedScheduler.newBuilder()
      .name("test-zk-logmetadata-store")
      .corePoolSize(1)
      .build();
  DistributedLogConfiguration conf = new DistributedLogConfiguration();
  conf.addConfiguration(baseConf);
  this.uri = createDLMURI("/" + runtime.getMethodName());
  metadataStore = new ZKLogMetadataStore(conf, uri, zkc, scheduler);
}