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

ZooReaderWriter.mkdirs介绍

暂无

代码示例

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

public void addWork(String workId, byte[] data) throws KeeperException, InterruptedException {
 if (workId.equalsIgnoreCase(LOCKS_NODE))
  throw new IllegalArgumentException("locks is reserved work id");
 zoo.mkdirs(path);
 zoo.putPersistentData(path + "/" + workId, data, NodeExistsPolicy.SKIP);
}

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

/**
  * Ensure that the full path to ZooKeeper nodes that will be used exist
  */
 public static void ensureZooKeeperInitialized(final ZooReaderWriter zooReaderWriter,
   final String zRoot) throws KeeperException, InterruptedException {
  if (!zooReaderWriter.exists(zRoot + ReplicationConstants.ZOO_TSERVERS, null)) {
   zooReaderWriter.mkdirs(zRoot + ReplicationConstants.ZOO_TSERVERS);
  }

  if (!zooReaderWriter.exists(zRoot + ReplicationConstants.ZOO_WORK_QUEUE, null)) {
   zooReaderWriter.mkdirs(zRoot + ReplicationConstants.ZOO_WORK_QUEUE);
  }
 }
}

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

public void addWork(String workId, byte[] data) throws KeeperException, InterruptedException {
 if (workId.equalsIgnoreCase(LOCKS_NODE))
  throw new IllegalArgumentException("locks is reserved work id");
 zoo.mkdirs(path);
 zoo.putPersistentData(path + "/" + workId, data, NodeExistsPolicy.SKIP);
}

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

zoo.mkdirs(path);
zoo.mkdirs(path + "/" + LOCKS_NODE);

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

zoo.mkdirs(path);
zoo.mkdirs(path + "/" + LOCKS_NODE);