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

ZKClusterClient.joinElection介绍

暂无

代码示例

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

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

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

) {
 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

) {
client.start();
RegistrationHandle node1 = client.joinElection("test-election", new ZKElectionListener() {

代码示例来源：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));
 }
}