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

ZooKeeperWatcher.close介绍

[英]Close the connection to ZooKeeper.
[中]关闭与ZooKeeper的连接。

代码示例

代码示例来源：origin: XiaoMi/themis

@Override
public void close() throws IOException {
 if (watcher != null) {
  watcher.close();
 }
}

代码示例来源：origin: harbby/presto-connectors

/**
  * Stop this tracker and the passed zookeeper
  */
 public void stop() {
  if (this.stopped) return;
  this.stopped = true;
  this.watcher.close();
 }
}

代码示例来源：origin: harbby/presto-connectors

protected void disconnect() {
 if (zkw != null) {
  zkw.close();
 }
}

代码示例来源：origin: harbby/presto-connectors

void internalClose(){
  super.close();
 }
}

代码示例来源：origin: co.cask.hbase/hbase

/**
 * Closes the current ZKW (if not null) and creates a new one
 * @throws IOException If anything goes wrong connecting
 */
public void reloadZkWatcher() throws IOException {
 if (zkw != null) zkw.close();
 zkw = new ZooKeeperWatcher(conf,
   "connection to cluster: " + id, this);    
}

代码示例来源：origin: harbby/presto-connectors

@Override
public void close() throws IOException {
 if (this.zkw != null) {
  this.zkw.close();
 }
 if (this.connection != null) {
  this.connection.close();
 }
}

代码示例来源：origin: harbby/presto-connectors

public void stop() {
 if (!this.stopped) {
  this.stopped = true;
  LOG.debug("Stopping HFileArchiveManager...");
  this.zooKeeper.close();
 }
}

代码示例来源：origin: harbby/presto-connectors

@Override
public void stop(String why) {
 if (this.stopped) return;
 this.stopped = true;
 if (this.zkw != null) {
  LOG.info("Stopping " + this.zkw);
  this.zkw.close();
 }
}

代码示例来源：origin: ucarGroup/DataLink

@Override
public void stop(String s) {
  this.zkWatcher.close();
  if (running) {
    running = false;
    rpcServer.stop();
    try {
      zkClient.delete(rsServerPath);
    } catch (Exception e) {
      if (e instanceof InterruptedException) {
        Thread.currentThread().interrupt();
      }
    }
  }
}

代码示例来源：origin: co.cask.hbase/hbase

void internalClose() {
 if (this.closed) {
  return;
 }
 master = null;
 this.servers.clear();
 if (this.rpcEngine != null) {
  this.rpcEngine.close();
 }
 if (this.zooKeeper != null) {
  LOG.info("Closed zookeeper sessionid=0x" +
   Long.toHexString(this.zooKeeper.getRecoverableZooKeeper().getSessionId()));
  this.zooKeeper.close();
  this.zooKeeper = null;
 }
 this.closed = true;
}

代码示例来源：origin: co.cask.hbase/hbase

private synchronized void resetZooKeeperTrackers() {
 if (masterAddressTracker != null) {
  masterAddressTracker.stop();
  masterAddressTracker = null;
 }
 if (rootRegionTracker != null) {
  rootRegionTracker.stop();
  rootRegionTracker = null;
 }
 clusterId = null;
 if (zooKeeper != null) {
  zooKeeper.close();
  zooKeeper = null;
 }
}

代码示例来源：origin: co.cask.hbase/hbase

@Override
public void stop(String why) {
 if (this.stopped) return;
 this.stopped = true;
 if (this.zkHelper != null) {
  LOG.info("Stopping " + this.zkHelper.getZookeeperWatcher());
  this.zkHelper.getZookeeperWatcher().close();
 }
 // Not sure why we're deleting a connection that we never acquired or used
 HConnectionManager.deleteConnection(this.getConf());
}

代码示例来源：origin: co.cask.hbase/hbase

/**
 * Delete a complete queue of hlogs
 * @param peerZnode znode of the peer cluster queue of hlogs to delete
 */
public void deleteSource(String peerZnode, boolean closeConnection) {
 try {
  ZKUtil.deleteNodeRecursively(this.zookeeper,
    ZKUtil.joinZNode(rsServerNameZnode, peerZnode));
  if (closeConnection) {
   this.peerClusters.get(peerZnode).getZkw().close();
   this.peerClusters.remove(peerZnode);
  }
 } catch (KeeperException e) {
  this.abortable.abort("Failed delete of " + peerZnode, e);
 }
}

代码示例来源：origin: harbby/presto-connectors

private ServerName getMetaRegionServerName(int replicaId)
throws IOException, KeeperException {
 ZooKeeperWatcher zkw = createZooKeeperWatcher();
 ServerName sn = null;
 try {
  sn = new MetaTableLocator().getMetaRegionLocation(zkw, replicaId);
 } finally {
  zkw.close();
 }
 return sn;
}

代码示例来源：origin: harbby/presto-connectors

private void checkAndFixTableLocks() throws IOException {
 ZooKeeperWatcher zkw = createZooKeeperWatcher();
 try {
  TableLockChecker checker = new TableLockChecker(zkw, errors);
  checker.checkTableLocks();
  if (this.fixTableLocks) {
   checker.fixExpiredTableLocks();
  }
 } finally {
  zkw.close();
 }
}

代码示例来源：origin: harbby/presto-connectors

private void unassignMetaReplica(HbckInfo hi) throws IOException, InterruptedException,
KeeperException {
 undeployRegions(hi);
 ZooKeeperWatcher zkw = createZooKeeperWatcher();
 try {
  ZKUtil.deleteNode(zkw, zkw.getZNodeForReplica(hi.metaEntry.getReplicaId()));
 } finally {
  zkw.close();
 }
}

代码示例来源：origin: XiaoMi/themis

@After
public void tearUp() throws IOException {
 try {
  ZKUtil.deleteNodeRecursively(zkw, ZookeeperWorkerRegister.THEMIS_ROOT_NODE);
 } catch (Exception e) {
  throw new IOException(e);
 }
 zkw.close();
 super.tearUp();
}

代码示例来源：origin: harbby/presto-connectors

/**
 * Closes the current ZKW (if not null) and creates a new one
 * @throws IOException If anything goes wrong connecting
 */
void reloadZkWatcher() throws IOException {
 if (zkw != null) zkw.close();
 zkw = new ZooKeeperWatcher(ctx.getConfiguration(),
   "connection to cluster: " + ctx.getPeerId(), this);
 getZkw().registerListener(new PeerRegionServerListener(this));
}

代码示例来源：origin: harbby/presto-connectors

private static void resetAcls(final Configuration conf, boolean eraseAcls)
  throws Exception {
 ZooKeeperWatcher zkw = new ZooKeeperWatcher(conf, "ZkAclReset", null);
 try {
  LOG.info((eraseAcls ? "Erase" : "Set") + " HBase ACLs for " +
       zkw.getQuorum() + " " + zkw.getBaseZNode());
  resetAcls(zkw, zkw.getBaseZNode(), eraseAcls);
 } finally {
  zkw.close();
 }
}

代码示例来源：origin: XiaoMi/themis

@Test
public void testSetExpiredTsToZk() throws Exception {
 long ts = System.currentTimeMillis() - 10l * 86400 * 1000;
 ThemisMasterObserver masterObserver = new ThemisMasterObserver();
 masterObserver.zk = new ZooKeeperWatcher(conf, "test", null, true);
 masterObserver.themisExpiredTsZNodePath = ThemisMasterObserver.getThemisExpiredTsZNodePath(masterObserver.zk);
 masterObserver.setExpiredTsToZk(ts);
 Assert.assertEquals(ts, ThemisMasterObserver.getThemisExpiredTsFromZk(masterObserver.zk));
 
 // test get data from not-exist path
 Assert.assertEquals(Long.MIN_VALUE,
  ThemisMasterObserver.getThemisExpiredTsFromZk(masterObserver.zk,
   masterObserver.themisExpiredTsZNodePath + "/" + System.currentTimeMillis()));
 masterObserver.zk.close();
}