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

ZooLock.deleteLock介绍

暂无

代码示例

代码示例来源：origin: org.apache.accumulo/accumulo-server-base

public static boolean deleteLock(String path, String lockData)
   throws InterruptedException, KeeperException {
  return deleteLock(ZooReaderWriter.getInstance(), path, lockData);
 }
}

代码示例来源：origin: org.apache.accumulo/accumulo-server

public static boolean deleteLock(String path, String lockData) throws InterruptedException, KeeperException {
  return deleteLock(ZooReaderWriter.getInstance(), path, lockData);
 }
}

代码示例来源：origin: org.apache.accumulo/accumulo-server

public static void deleteLock(String path) throws InterruptedException, KeeperException {
 deleteLock(ZooReaderWriter.getInstance(), path);
}

代码示例来源：origin: org.apache.accumulo/accumulo-server-base

public static void deleteLock(String path) throws InterruptedException, KeeperException {
 deleteLock(ZooReaderWriter.getInstance(), path);
}

代码示例来源：origin: org.apache.accumulo/accumulo-server

public static void main(String[] args) throws Exception {
 Instance instance = HdfsZooInstance.getInstance();
 String tserverPath = ZooUtil.getRoot(instance) + Constants.ZTSERVERS;
 Opts opts = new Opts();
 opts.parseArgs(TabletServerLocks.class.getName(), args);
 ZooCache cache = new ZooCache(instance.getZooKeepers(), instance.getZooKeepersSessionTimeOut());
 if (opts.list) {
  IZooReaderWriter zoo = ZooReaderWriter.getInstance();
  List<String> tabletServers = zoo.getChildren(tserverPath);
  for (String tabletServer : tabletServers) {
   byte[] lockData = ZooLock.getLockData(cache, tserverPath + "/" + tabletServer, null);
   String holder = null;
   if (lockData != null) {
    holder = new String(lockData, UTF_8);
   }
   System.out.printf("%32s %16s%n", tabletServer, holder);
  }
 } else if (opts.delete != null) {
  ZooLock.deleteLock(tserverPath + "/" + args[1]);
 } else {
  System.out.println("Usage : " + TabletServerLocks.class.getName() + " -list|-delete <tserver lock>");
 }
}

代码示例来源：origin: org.apache.accumulo/accumulo-server-base

public static void main(String[] args) throws Exception {
 Instance instance = HdfsZooInstance.getInstance();
 String tserverPath = ZooUtil.getRoot(instance) + Constants.ZTSERVERS;
 Opts opts = new Opts();
 opts.parseArgs(TabletServerLocks.class.getName(), args);
 ZooCache cache = new ZooCache(instance.getZooKeepers(), instance.getZooKeepersSessionTimeOut());
 if (opts.list) {
  IZooReaderWriter zoo = ZooReaderWriter.getInstance();
  List<String> tabletServers = zoo.getChildren(tserverPath);
  for (String tabletServer : tabletServers) {
   byte[] lockData = ZooLock.getLockData(cache, tserverPath + "/" + tabletServer, null);
   String holder = null;
   if (lockData != null) {
    holder = new String(lockData, UTF_8);
   }
   System.out.printf("%32s %16s%n", tabletServer, holder);
  }
 } else if (opts.delete != null) {
  ZooLock.deleteLock(tserverPath + "/" + args[1]);
 } else {
  System.out.println(
    "Usage : " + TabletServerLocks.class.getName() + " -list|-delete <tserver lock>");
 }
}

代码示例来源：origin: org.apache.accumulo/accumulo-master

@Override
public Repo<Master> call(long tid, Master master) throws Exception {
 // suppress assignment of tablets to the server
 if (force) {
  String path = ZooUtil.getRoot(master.getInstance()) + Constants.ZTSERVERS + "/"
    + server.getLocation();
  ZooLock.deleteLock(path);
  path = ZooUtil.getRoot(master.getInstance()) + Constants.ZDEADTSERVERS + "/"
    + server.getLocation();
  IZooReaderWriter zoo = ZooReaderWriter.getInstance();
  zoo.putPersistentData(path, "forced down".getBytes(UTF_8), NodeExistsPolicy.OVERWRITE);
 }
 return null;
}

代码示例来源：origin: org.apache.accumulo/accumulo-server

String path = tserversPath + "/" + child;
if (zoo.getChildren(path).size() > 0) {
 if (!ZooLock.deleteLock(path, "tserver")) {
  message("Did not delete " + tserversPath + "/" + child, opts);

代码示例来源：origin: org.apache.accumulo/accumulo-server

String tserver = AddressUtil.toString(server.getLocation());
String path = ZooUtil.getRoot(master.getInstance()) + Constants.ZTSERVERS + "/" + tserver;
ZooLock.deleteLock(path);
path = ZooUtil.getRoot(master.getInstance()) + Constants.ZDEADTSERVERS + "/" + tserver;
IZooReaderWriter zoo = ZooReaderWriter.getInstance();

代码示例来源：origin: org.apache.accumulo/accumulo-server-base

String path = tserversPath + "/" + child;
if (zoo.getChildren(path).size() > 0) {
 if (!ZooLock.deleteLock(path, "tserver")) {
  message("Did not delete " + tserversPath + "/" + child, opts);