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

ZooUtil介绍

暂无

代码示例

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

protected ZooConfiguration(String instanceId, ZooCache propCache, AccumuloConfiguration parent) {
 this.propCache = propCache;
 this.parent = parent;
 this.propPathPrefix = ZooUtil.getRoot(instanceId) + Constants.ZCONFIG;
}

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

/**
 * Utility to support certain client side utilities to minimize command-line options.
 */
public static String getInstanceIDFromHdfs(Path instanceDirectory, AccumuloConfiguration conf) {
 return getInstanceIDFromHdfs(instanceDirectory, conf, CachedConfiguration.getInstance());
}

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

@Override
public List<String> getMasterLocations() {
 String masterLocPath = ZooUtil.getRoot(this) + Constants.ZMASTER_LOCK;
 OpTimer timer = null;
 if (log.isTraceEnabled()) {
  log.trace("tid={} Looking up master location in zookeeper.", Thread.currentThread().getId());
  timer = new OpTimer().start();
 }
 byte[] loc = ZooUtil.getLockData(zooCache, masterLocPath);
 if (timer != null) {
  timer.stop();
  log.trace("tid={} Found master at {} in {}", Thread.currentThread().getId(),
    (loc == null ? "null" : new String(loc, UTF_8)),
    String.format("%.3f secs", timer.scale(TimeUnit.SECONDS)));
 }
 if (loc == null) {
  return Collections.emptyList();
 }
 return Collections.singletonList(new String(loc, UTF_8));
}

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

String instanceIdFromFile = ZooUtil.getInstanceIDFromHdfs(instanceIdPath, cc, hadoopConf);
IZooReaderWriter zrw = new ZooReaderWriterFactory().getZooReaderWriter(
  cc.get(Property.INSTANCE_ZK_HOST), (int) cc.getTimeInMillis(Property.INSTANCE_ZK_TIMEOUT),
  cc.get(Property.INSTANCE_SECRET));
String rootPath = ZooUtil.getRoot(instanceIdFromFile);

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

private static void initZooKeeper(Opts opts, String uuid, String instanceNamePath) throws KeeperException, InterruptedException {
 ZooUtil.putPersistentData(zoo.getZooKeeper(), Constants.ZROOT, new byte[0], -1, NodeExistsPolicy.SKIP, Ids.OPEN_ACL_UNSAFE);
 ZooUtil.putPersistentData(zoo.getZooKeeper(), Constants.ZROOT + Constants.ZINSTANCES, new byte[0], -1, NodeExistsPolicy.SKIP, Ids.OPEN_ACL_UNSAFE);

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

/**
 * Get the parent ZNode for tservers for the given instance
 *
 * @param instance
 *          The Instance
 * @return The tservers znode for the instance
 */
static String getTServersZkPath(Instance instance) {
 requireNonNull(instance);
 final String instanceRoot = ZooUtil.getRoot(instance);
 return instanceRoot + Constants.ZTSERVERS;
}

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

ZooCache zc = new ZooCacheFactory().getZooCache(instance.getZooKeepers(),
  instance.getZooKeepersSessionTimeOut());
for (String tserver : zc.getChildren(ZooUtil.getRoot(instance) + Constants.ZTSERVERS)) {
 String path = ZooUtil.getRoot(instance) + Constants.ZTSERVERS + "/" + tserver;
 byte[] data = ZooUtil.getLockData(zc, path);
 if (data != null) {
  String strData = new String(data, UTF_8);

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

private static synchronized void _getInstanceID() {
 if (instanceId == null) {
  AccumuloConfiguration acuConf = SiteConfiguration.getInstance();
  // InstanceID should be the same across all volumes, so just choose one
  VolumeManager fs;
  try {
   fs = VolumeManagerImpl.get();
  } catch (IOException e) {
   throw new RuntimeException(e);
  }
  Path instanceIdPath = Accumulo.getAccumuloInstanceIdPath(fs);
  log.trace("Looking for instanceId from {}", instanceIdPath);
  String instanceIdFromFile = ZooUtil.getInstanceIDFromHdfs(instanceIdPath, acuConf);
  instanceId = instanceIdFromFile;
 }
}

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

NamespaceConfWatcher(Instance instance) {
 this.instance = instance;
 namespacesPrefix = ZooUtil.getRoot(instance) + Constants.ZNAMESPACES + "/";
 namespacesPrefixLength = namespacesPrefix.length();
 scf = new ServerConfigurationFactory(instance);
}

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

for (String tserver : zc.getChildren(ZooUtil.getRoot(instance) + Constants.ZTSERVERS)) {
 String path = ZooUtil.getRoot(instance) + Constants.ZTSERVERS + "/" + tserver;
 byte[] data = ZooUtil.getLockData(zc, path);
 if (data != null) {
  String strData = new String(data, UTF_8);

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

Integer currentVersion;
try {
 currentIid = ZooUtil.getInstanceIDFromHdfs(path, SiteConfiguration.getInstance());
 Path vpath = new Path(baseDir, VERSION_DIR);
 currentVersion = Accumulo.getAccumuloPersistentVersion(

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

private String get(String key) {
 String zPath = ZooUtil.getRoot(instanceId) + Constants.ZCONFIG + "/" + key;
 byte[] v = propCache.get(zPath);
 String value = null;
 if (v != null)
  value = new String(v, UTF_8);
 return value;
}

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

private static void addVolumes(VolumeManager fs) throws IOException {
 String[] volumeURIs = VolumeConfiguration.getVolumeUris(SiteConfiguration.getInstance());
 HashSet<String> initializedDirs = new HashSet<>();
 initializedDirs.addAll(Arrays.asList(ServerConstants.checkBaseUris(volumeURIs, true)));
 HashSet<String> uinitializedDirs = new HashSet<>();
 uinitializedDirs.addAll(Arrays.asList(volumeURIs));
 uinitializedDirs.removeAll(initializedDirs);
 Path aBasePath = new Path(initializedDirs.iterator().next());
 Path iidPath = new Path(aBasePath, ServerConstants.INSTANCE_ID_DIR);
 Path versionPath = new Path(aBasePath, ServerConstants.VERSION_DIR);
 UUID uuid = UUID
   .fromString(ZooUtil.getInstanceIDFromHdfs(iidPath, SiteConfiguration.getInstance()));
 for (Pair<Path,Path> replacementVolume : ServerConstants.getVolumeReplacements()) {
  if (aBasePath.equals(replacementVolume.getFirst()))
   log.error(aBasePath + " is set to be replaced in " + Property.INSTANCE_VOLUMES_REPLACEMENTS
     + " and should not appear in " + Property.INSTANCE_VOLUMES
     + ". It is highly recommended that this property be removed as data"
     + " could still be written to this volume.");
 }
 if (ServerConstants.DATA_VERSION != Accumulo.getAccumuloPersistentVersion(
   versionPath.getFileSystem(CachedConfiguration.getInstance()), versionPath)) {
  throw new IOException("Accumulo " + Constants.VERSION + " cannot initialize data version "
    + Accumulo.getAccumuloPersistentVersion(fs));
 }
 initDirs(fs, uuid, uinitializedDirs.toArray(new String[uinitializedDirs.size()]), true);
}

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

public MonitorLog4jWatcher(String instance, String filename, int delay) {
 super(filename);
 setDelay(delay);
 this.path = ZooUtil.getRoot(instance) + Constants.ZMONITOR_LOG4J_ADDR;
 this.lock = new Object();
}

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

String instanceIDFromFile = ZooUtil.getInstanceIDFromHdfs(instanceDir, config);
if (config.getBoolean(Property.INSTANCE_RPC_SSL_ENABLED))
 clientConfig.setProperty(ClientProperty.INSTANCE_RPC_SSL_ENABLED, "true");

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

private String getPath() {
 return ZooUtil.getRoot(instance.getInstanceID()) + Constants.ZTABLES + "/" + tableId
   + Constants.ZTABLE_CONF;
}

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

private static Instance getZooInstance(String instanceName, String keepersOption,
  ClientConfiguration clientConfig) {
 UUID instanceId = null;
 if (instanceName == null) {
  instanceName = clientConfig.get(ClientProperty.INSTANCE_NAME);
 }
 String keepers = getZooKeepers(keepersOption, clientConfig);
 if (instanceName == null) {
  AccumuloConfiguration conf = SiteConfiguration.getInstance();
  Path instanceDir = new Path(VolumeConfiguration.getVolumeUris(conf)[0], "instance_id");
  instanceId = UUID.fromString(ZooUtil.getInstanceIDFromHdfs(instanceDir, conf));
 }
 if (instanceId != null) {
  return new ZooKeeperInstance(clientConfig.withInstance(instanceId).withZkHosts(keepers));
 } else {
  return new ZooKeeperInstance(clientConfig.withInstance(instanceName).withZkHosts(keepers));
 }
}

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

public static String getRoot(final Instance instance) {
 return getRoot(instance.getInstanceID());
}

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

instanceId = ZooUtil.getInstanceIDFromHdfs(instanceIdPath, parent);
} else {
 instanceId = inst.getInstanceID();

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

public NamespaceConfiguration(String namespaceId, Instance inst, AccumuloConfiguration parent) {
 this.inst = inst;
 this.parent = parent;
 this.namespaceId = namespaceId;
 this.path = ZooUtil.getRoot(inst.getInstanceID()) + Constants.ZNAMESPACES + "/" + namespaceId
   + Constants.ZNAMESPACE_CONF;
}