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

ZKClientService.stopAndWait介绍

暂无

代码示例

代码示例来源：origin: apache/phoenix

@Override
public void close() throws IOException {
  zkClient.stopAndWait();
}

代码示例来源：origin: apache/phoenix

@Override
public void close() throws IOException {
  try {
    if (txService != null) txService.stopAndWait();
  } finally {
    if (zkClient != null) zkClient.stopAndWait();
  }
}

代码示例来源：origin: cdapio/cdap

@Override
 public void close() {
  // zkClientService is null if used by the Explore service,
  // since Explore manages the lifecycle of the zk service. it is not null if used by a MR job launched by Hive.
  if (zkClientService != null) {
   zkClientService.stopAndWait();
  }
 }
}

代码示例来源：origin: co.cask.cdap/cdap-explore

@Override
 public void close() {
  // zkClientService is null if used by the Explore service,
  // since Explore manages the lifecycle of the zk service. it is not null if used by a MR job launched by Hive.
  if (zkClientService != null) {
   zkClientService.stopAndWait();
  }
 }
}

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

@Override
public void close() throws IOException {
  zkClient.stopAndWait();
}

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

@Override
public void close() throws IOException {
  try {
    if (txService != null) txService.stopAndWait();
  } finally {
    if (zkClient != null) zkClient.stopAndWait();
  }
}

代码示例来源：origin: com.aliyun.phoenix/ali-phoenix-core

@Override
public void close() throws IOException {
  try {
    if (txService != null) txService.stopAndWait();
  } finally {
    if (zkClient != null) zkClient.stopAndWait();
  }
}

代码示例来源：origin: caskdata/tephra

/**
 * Frees up the underlying resources common to all clients.
 */
public void close() {
 try {
  if (conn != null) {
   conn.close();
  }
 } catch (IOException ignored) { }
 if (zkClient != null) {
  zkClient.stopAndWait();
 }
}

代码示例来源：origin: cdapio/cdap

/**
 * Stop services and
 */
private void stop() {
 try {
  txService.stopAndWait();
  zkClientService.stopAndWait();
 } catch (Throwable e) {
  LOG.error("Exception while trying to stop upgrade process", e);
  Runtime.getRuntime().halt(1);
 }
}

代码示例来源：origin: caskdata/coopr

@After
public void after() {
 zkClient.stopAndWait();
 zkServer.stopAndWait();
}

代码示例来源：origin: caskdata/coopr

@After
public void after() {
 zkClient.stopAndWait();
 zkServer.stopAndWait();
}

代码示例来源：origin: cdapio/cdap

@AfterClass
public static void finish() throws Exception {
 zkClientService.stopAndWait();
 zkServer.stopAndWait();
}

代码示例来源：origin: cdapio/cdap

@AfterClass
public static void finish() {
 zkClient.stopAndWait();
 zkServer.stopAndWait();
}

代码示例来源：origin: caskdata/coopr

@After
public void after() {
 zkClient.stopAndWait();
 zkServer.stopAndWait();
}

代码示例来源：origin: caskdata/coopr

@AfterClass
public static void afterClass() {
 zkClient.stopAndWait();
 zkServer.stopAndWait();
}

代码示例来源：origin: caskdata/tephra

@AfterClass
public static void stop() throws Exception {
 txService.stopAndWait();
 zkClientService.stopAndWait();
 zkServer.stopAndWait();
}

代码示例来源：origin: caskdata/coopr

@AfterClass
public static void teardownBase() {
 zkClientService.stopAndWait();
 zkServer.stopAndWait();
 DBHelper.dropDerbyDB();
}

代码示例来源：origin: caskdata/cdap

@Override
protected void after() {
 brokerService.stopAndWait();
 kafkaClient.stopAndWait();
 zkClient.stopAndWait();
 kafkaServer.stopAndWait();
 zkServer.stopAndWait();
}

代码示例来源：origin: caskdata/tephra

@AfterClass
public static void stop() throws Exception {
 txService.stopAndWait();
 storage.stopAndWait();
 zkClientService.stopAndWait();
 zkServer.stopAndWait();
}

代码示例来源：origin: caskdata/tephra

@AfterClass
public static void stop() throws Exception {
 txService.stopAndWait();
 storage.stopAndWait();
 zkClientService.stopAndWait();
 zkServer.stopAndWait();
}