Java 类org.apache.hadoop.hbase.util.hbck.TableLockChecker 实例源码

项目:ditb    文件:HBaseFsck.java   
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();
  }
}
项目:pbase    文件:HBaseFsck.java   
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();
  }
}
项目:HIndex    文件:HBaseFsck.java   
private void checkAndFixTableLocks() throws IOException {
  TableLockChecker checker = new TableLockChecker(createZooKeeperWatcher(), errors);
  checker.checkTableLocks();

  if (this.fixTableLocks) {
    checker.fixExpiredTableLocks();
  }
}
项目:PyroDB    文件:HBaseFsck.java   
private void checkAndFixTableLocks() throws IOException {
  TableLockChecker checker = new TableLockChecker(createZooKeeperWatcher(), errors);
  checker.checkTableLocks();

  if (this.fixTableLocks) {
    checker.fixExpiredTableLocks();
  }
}
项目:c5    文件:HBaseFsck.java   
private void checkAndFixTableLocks() throws IOException {
  TableLockChecker checker = new TableLockChecker(createZooKeeperWatcher(), errors);
  checker.checkTableLocks();

  if (this.fixTableLocks) {
    checker.fixExpiredTableLocks();
  }
}