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

ZKClusterClient介绍

暂无

代码示例

代码示例来源：origin: dremio/dremio-oss

public ZKClusterCoordinator(SabotConfig config, String connect) throws IOException {
 this.zkClient = new ZKClusterClient(config, connect);
}

代码示例来源：origin: dremio/dremio-oss

@Override
public RegistrationHandle joinElection(String name, ElectionListener listener) {
 return zkClient.joinElection(name, listener);
}

代码示例来源：origin: dremio/dremio-oss

@Override
public void start() throws Exception {
 zkClient.start();
 if (!closed) {
  Thread.sleep(5);
  for(Service service: Service.values()) {
   ZKServiceSet serviceSet = zkClient.newServiceSet(service.name);
   serviceSet.start();
   serviceSets.put(service.role.name(), serviceSet);
  }
  logger.info("ZKClusterCoordination is up");
 }
}

代码示例来源：origin: dremio/dremio-oss

@Test
public void test3ComponentsConnection() throws Exception {
 assertNull(zooKeeperServer.getZKClient().exists("/dremio3/test/test-cluster-id", false));
 try(ZKClusterClient client = new ZKClusterClient(
   DEFAULT_SABOT_CONFIG,
   String.format("%s/dremio3/test/test-cluster-id", zooKeeperServer.getConnectString()))
 ) {
  client.start();
  ZKServiceSet serviceSet = client.newServiceSet("coordinator");
  serviceSet.register(NodeEndpoint.newBuilder().setAddress("foo").build());
  Stat stat = zooKeeperServer.getZKClient().exists("/dremio3/test/test-cluster-id/coordinator", false);
  assertNotNull(stat);
  assertEquals(1, stat.getNumChildren());
 }
}

代码示例来源：origin: dremio/dremio-oss

try(ZKClusterClient client = new ZKClusterClient(
  DEFAULT_SABOT_CONFIG,
  String.format("%s/dremio/test/test-cluster-id", zooKeeperServer.getConnectString()))
) {
 client.start();
 RegistrationHandle node1 = client.joinElection("test-election", new ElectionListener() {
 RegistrationHandle node2 = client.joinElection("test-election", new ElectionListener() {
  @Override
  public void onElected() {

代码示例来源：origin: dremio/dremio-oss

@Override
public synchronized ServiceSet getOrCreateServiceSet(final String serviceName) {
 return serviceSets.computeIfAbsent(serviceName, s -> {
  final ZKServiceSet newServiceSet = zkClient.newServiceSet(serviceName);
  try {
   newServiceSet.start();
  } catch (Exception e) {
   throw new RuntimeException(String.format("Unable to start %s service in Zookeeper", serviceName), e);
  }
  return newServiceSet;
 });
}

代码示例来源：origin: dremio/dremio-oss

/**
 * Kill the given ZK session
 *
 * @param clusterCoordinator the cluster coordinator owning the session
 */
public static void kill(ZKClusterCoordinator clusterCoordinator) throws Exception {
 KillSession.kill(clusterCoordinator.getZkClient().getZooKeeperClient(), clusterCoordinator.getZkClient().getConnectionString());
}

代码示例来源：origin: dremio/dremio-oss

@Override
public DistributedSemaphore getSemaphore(String name, int maximumLeases) {
 return zkClient.getSemaphore(name, maximumLeases);
}

代码示例来源：origin: dremio/dremio-oss

curator.getConnectionStateListenable().addListener(new ConnectionLogger());
curator.start();
discovery = newDiscovery(clusterId);

代码示例来源：origin: dremio/dremio-oss

@Test
public void test1ComponentConnection() throws Exception {
 assertNull(zooKeeperServer.getZKClient().exists("/dremio1", false));
 try(ZKClusterClient client = new ZKClusterClient(
   DEFAULT_SABOT_CONFIG,
   String.format("%s/dremio1", zooKeeperServer.getConnectString()))
 ) {
  client.start();
  ZKServiceSet serviceSet = client.newServiceSet("coordinator");
  serviceSet.register(NodeEndpoint.newBuilder().setAddress("foo").build());
  Stat stat = zooKeeperServer.getZKClient().exists("/dremio1/coordinator", false);
  assertNotNull(stat);
  assertEquals(1, stat.getNumChildren());
 }
}

代码示例来源：origin: dremio/dremio-oss

@Test
public void testElectionDisconnection() throws Exception {
 final CountDownLatch elected = new CountDownLatch(1);
 final CountDownLatch cancelled = new CountDownLatch(1);
 try(ZKClusterClient client = new ZKClusterClient(
   DEFAULT_SABOT_CONFIG
   .withValue(ClusterCoordinator.Options.ZK_ELECTION_POLLING, ConfigValueFactory.fromAnyRef("20ms"))
   .withValue(ClusterCoordinator.Options.ZK_ELECTION_TIMEOUT, ConfigValueFactory.fromAnyRef("100ms")),
   String.format("%s/dremio/test/test-cluster-id", zooKeeperServer.getConnectString()))
 ) {
  client.start();
  RegistrationHandle node1 = client.joinElection("test-election", new ElectionListener() {
   @Override
   public void onElected() {
    elected.countDown();
   }
   @Override
   public void onCancelled() {
    cancelled.countDown();
   }
  });
  assertTrue("No election happened", elected.await(5, TimeUnit.SECONDS));
  // Kill the server to force disconnection
  zooKeeperServer.closeServer();
  assertTrue("Node was not notified about cancellation", cancelled.await(5, TimeUnit.SECONDS));
 }
}

代码示例来源：origin: dremio/dremio-oss

@Test
public void test2ComponentsConnection() throws Exception {
 assertNull(zooKeeperServer.getZKClient().exists("/dremio2/test-cluster-id", false));
 try(ZKClusterClient client = new ZKClusterClient(
   DEFAULT_SABOT_CONFIG,
   String.format("%s/dremio2/test-cluster-id", zooKeeperServer.getConnectString()))
 ) {
  client.start();
  ZKServiceSet serviceSet = client.newServiceSet("coordinator");
  serviceSet.register(NodeEndpoint.newBuilder().setAddress("foo").build());
  Stat stat = zooKeeperServer.getZKClient().exists("/dremio2/test-cluster-id/coordinator", false);
  assertNotNull(stat);
  assertEquals(1, stat.getNumChildren());
 }
}

代码示例来源：origin: dremio/dremio-oss

final CountDownLatch reconnected = new CountDownLatch(1);
try(ZKClusterClient client = new ZKClusterClient(
  DEFAULT_SABOT_CONFIG
  .withValue(ClusterCoordinator.Options.ZK_ELECTION_POLLING, ConfigValueFactory.fromAnyRef("250ms"))
  String.format("%s/dremio/test/test-cluster-id", zooKeeperServer.getConnectString()))
  ) {
 client.start();
 RegistrationHandle node1 = client.joinElection("test-election", new ZKElectionListener() {

代码示例来源：origin: dremio/dremio-oss

public ZKClusterCoordinator(SabotConfig config, Provider<Integer> localPort) throws IOException {
 this.zkClient = new ZKClusterClient(config, localPort);
}

代码示例来源：origin: dremio/dremio-oss

@Test
public void testDefaultConnection() throws Exception {
 // Default root from sabot-module.conf
 assertNull(zooKeeperServer.getZKClient().exists("/dremio/test-path", false));
 final SabotConfig config = DEFAULT_SABOT_CONFIG
   .withValue(ZK_ROOT, ConfigValueFactory.fromAnyRef("dremio/test-path"))
   .withValue(CLUSTER_ID, ConfigValueFactory.fromAnyRef("test-cluster-id"));
 try(ZKClusterClient client = new ZKClusterClient(config, new Provider<Integer>() {
  @Override
  public Integer get() {
   return zooKeeperServer.getPort();
  }
 })) {
  client.start();
  ZKServiceSet serviceSet = client.newServiceSet("coordinator");
  serviceSet.register(NodeEndpoint.newBuilder().setAddress("foo").build());
  Stat stat = zooKeeperServer.getZKClient().exists("/dremio/test-path/test-cluster-id/coordinator", false);
  assertNotNull(stat);
  assertEquals(1, stat.getNumChildren());
 }
}