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

ZkClientx.delete介绍

暂无

代码示例

代码示例来源：origin: alibaba/canal

private void releaseCid(String path) {
  // logger.info("## release the canalId = {}", cid);
  // 初始化系统目录
  if (zkclientx != null) {
    zkclientx.delete(path);
  }
}

代码示例来源：origin: alibaba/canal

private boolean releaseRunning() {
  if (check()) {
    String path = ZookeeperPathUtils.getDestinationServerRunning(destination);
    zkClient.delete(path);
    mutex.set(false);
    processActiveExit();
    return true;
  }
  return false;
}

代码示例来源：origin: alibaba/canal

public void clearAllBatchs(ClientIdentity clientIdentity) throws CanalMetaManagerException {
  String path = ZookeeperPathUtils.getBatchMarkPath(clientIdentity.getDestination(),
    clientIdentity.getClientId());
  List<String> batchChilds = zkClientx.getChildren(path);
  for (String batchChild : batchChilds) {
    String batchPath = path + ZookeeperPathUtils.ZOOKEEPER_SEPARATOR + batchChild;
    zkClientx.delete(batchPath);
  }
}

代码示例来源：origin: alibaba/canal

public PositionRange removeBatch(ClientIdentity clientIdentity, Long batchId) throws CanalMetaManagerException {
  String batchsPath = ZookeeperPathUtils.getBatchMarkPath(clientIdentity.getDestination(),
    clientIdentity.getClientId());
  List<String> nodes = zkClientx.getChildren(batchsPath);
  if (CollectionUtils.isEmpty(nodes)) {
    // 没有batch记录
    return null;
  }
  // 找到最小的Id
  ArrayList<Long> batchIds = new ArrayList<Long>(nodes.size());
  for (String batchIdString : nodes) {
    batchIds.add(Long.valueOf(batchIdString));
  }
  Long minBatchId = Collections.min(batchIds);
  if (!minBatchId.equals(batchId)) {
    // 检查一下提交的ack/rollback，必须按batchId分出去的顺序提交，否则容易出现丢数据
    throw new CanalMetaManagerException(String.format("batchId:%d is not the firstly:%d", batchId, minBatchId));
  }
  if (!batchIds.contains(batchId)) {
    // 不存在对应的batchId
    return null;
  }
  PositionRange positionRange = getBatch(clientIdentity, batchId);
  if (positionRange != null) {
    String path = ZookeeperPathUtils
      .getBatchMarkWithIdPath(clientIdentity.getDestination(), clientIdentity.getClientId(), batchId);
    zkClientx.delete(path);
  }
  return positionRange;
}

代码示例来源：origin: alibaba/canal

public boolean releaseRunning() {
  if (check()) {
    String path = ZookeeperPathUtils.getDestinationClientRunning(this.destination, clientData.getClientId());
    zkClient.delete(path);
    mutex.set(false);
    processActiveExit();
    return true;
  }
  return false;
}

代码示例来源：origin: com.alibaba.otter/canal.deployer

private void releaseCid(String path) {
  // logger.info("## release the canalId = {}", cid);
  // 初始化系统目录
  if (zkclientx != null) {
    zkclientx.delete(path);
  }
}

代码示例来源：origin: com.alibaba.otter/canal.client

public boolean releaseRunning() {
  if (check()) {
    String path = ZookeeperPathUtils.getDestinationClientRunning(this.destination, clientData.getClientId());
    zkClient.delete(path);
    mutex.set(false);
    processActiveExit();
    return true;
  }
  return false;
}