org.apache.accumulo.server.zookeeper.ZooReaderWriter.exists()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(10.0k)|赞(0)|评价(0)|浏览(138)

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

ZooReaderWriter.exists介绍

暂无

代码示例

代码示例来源：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

@Override
public void run() {
 try {
  // Initially set the logger if the Monitor's log4j advertisement node exists
  if (ZooReaderWriter.getInstance().exists(path, this))
   updateMonitorLog4jLocation();
  log.info("Set watch for Monitor Log4j watcher");
 } catch (Exception e) {
  log.error("Unable to set watch for Monitor Log4j watcher on " + path);
 }
 super.run();
}

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

@Override
public void run() {
 try {
  // Initially set the logger if the Monitor's log4j advertisement node exists
  if (ZooReaderWriter.getInstance().exists(path, this))
   updateMonitorLog4jLocation();
  log.info("Set watch for Monitor Log4j watcher");
 } catch (Exception e) {
  log.error("Unable to set watch for Monitor Log4j watcher on " + path);
 }
 super.run();
}

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

/**
 * Add the given {@link AuthenticationKey} to ZooKeeper.
 *
 * @param newKey
 *          The key to add to ZooKeeper
 */
public synchronized void advertise(AuthenticationKey newKey)
  throws KeeperException, InterruptedException {
 checkState(initialized.get(), "Not initialized");
 requireNonNull(newKey);
 // Make sure the node doesn't already exist
 String path = qualifyPath(newKey);
 if (zk.exists(path)) {
  log.warn("AuthenticationKey with ID '{}' already exists in ZooKeeper", newKey.getKeyId());
  return;
 }
 // Serialize it
 ByteArrayOutputStream baos = new ByteArrayOutputStream(4096);
 try {
  newKey.write(new DataOutputStream(baos));
 } catch (IOException e) {
  throw new AssertionError("Should not get exception writing to in-memory buffer", e);
 }
 byte[] serializedKey = baos.toByteArray();
 log.debug("Advertising AuthenticationKey with keyId {} in ZooKeeper at {}", newKey.getKeyId(),
   path);
 // Put it into ZK with the private ACL
 zk.putPrivatePersistentData(path, serializedKey, NodeExistsPolicy.FAIL);
}

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

if (!zk.exists(baseNode)) {
 if (!zk.putPrivatePersistentData(baseNode, new byte[0], NodeExistsPolicy.FAIL)) {
  throw new AssertionError("Got false from putPrivatePersistentData method");

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

/**
 * Remove the given {@link AuthenticationKey} from ZooKeeper. If the node for the provided
 * {@code key} doesn't exist in ZooKeeper, a warning is printed but an error is not thrown. Since
 * there is only a single process managing ZooKeeper at one time, any inconsistencies should be
 * client error.
 *
 * @param key
 *          The key to remove from ZooKeeper
 */
public synchronized void remove(AuthenticationKey key)
  throws KeeperException, InterruptedException {
 checkState(initialized.get(), "Not initialized");
 requireNonNull(key);
 String path = qualifyPath(key);
 if (!zk.exists(path)) {
  log.warn("AuthenticationKey with ID '{}' doesn't exist in ZooKeeper", key.getKeyId());
  return;
 }
 log.debug("Removing AuthenticationKey with keyId {} from ZooKeeper at {}", key.getKeyId(),
   path);
 // Delete the node, any version
 zk.delete(path, -1);
}

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

private String root() throws WalMarkerException {
 String root = ZooUtil.getRoot(instance) + ZWALS;
 try {
  if (!checkedExistance && !zoo.exists(root)) {
   zoo.putPersistentData(root, new byte[0], NodeExistsPolicy.SKIP);
  }
  checkedExistance = true;
 } catch (KeeperException | InterruptedException e) {
  throw new WalMarkerException(e);
 }
 return root;
}

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

@Override
public void process(WatchedEvent event) {
 // We got an update, process the data in the node
 updateMonitorLog4jLocation();
 if (event.getPath() != null) {
  try {
   ZooReaderWriter.getInstance().exists(event.getPath(), this);
  } catch (Exception ex) {
   log.error("Unable to reset watch for Monitor Log4j watcher", ex);
  }
 }
}

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

@Override
public void process(WatchedEvent event) {
 log.debug("event " + event.getPath() + " " + event.getType() + " " + event.getState());
 if (event.getState() == KeeperState.Expired) {
  log.warn("Trace server lost zookeeper registration at " + event.getPath());
  server.stop();
 } else if (event.getType() == EventType.NodeDeleted) {
  log.warn("Trace server zookeeper entry lost " + event.getPath());
  server.stop();
 }
 if (event.getPath() != null) {
  try {
   if (ZooReaderWriter.getInstance().exists(event.getPath(), this))
    return;
  } catch (Exception ex) {
   log.error("{}", ex.getMessage(), ex);
  }
  log.warn("Trace server unable to reset watch on zookeeper registration");
  server.stop();
 }
}

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

@Override
public void process(WatchedEvent event) {
 // We got an update, process the data in the node
 updateMonitorLog4jLocation();
 if (event.getPath() != null) {
  try {
   ZooReaderWriter.getInstance().exists(event.getPath(), this);
  } catch (Exception ex) {
   log.error("Unable to reset watch for Monitor Log4j watcher", ex);
  }
 }
}

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

if (!zoo.exists(childPath)) {
 zoo.recursiveDelete(lockPath, NodeMissingPolicy.SKIP);
 continue;

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

if (!zoo.exists(childPath)) {
 zoo.recursiveDelete(lockPath, NodeMissingPolicy.SKIP);
 continue;

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

@Override
public void process(WatchedEvent event) {
 log.debug("event " + event.getPath() + " " + event.getType() + " " + event.getState());
 if (event.getState() == KeeperState.Expired) {
  log.warn("Trace server lost zookeeper registration at " + event.getPath());
  server.stop();
 } else if (event.getType() == EventType.NodeDeleted) {
  log.warn("Trace server zookeeper entry lost " + event.getPath());
  server.stop();
 }
 if (event.getPath() != null) {
  try {
   if (ZooReaderWriter.getInstance().exists(event.getPath(), this))
    return;
  } catch (Exception ex) {
   log.error(ex, ex);
  }
  log.warn("Trace server unable to reset watch on zookeeper registration");
  server.stop();
 }
}

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

public static void main(String[] args) throws Exception {
  ClientOpts opts = new ClientOpts();
  opts.parseArgs(MergeStats.class.getName(), args);

  Connector conn = opts.getConnector();
  Map<String,String> tableIdMap = conn.tableOperations().tableIdMap();
  for (Entry<String,String> entry : tableIdMap.entrySet()) {
   final String table = entry.getKey(), tableId = entry.getValue();
   String path = ZooUtil.getRoot(conn.getInstance().getInstanceID()) + Constants.ZTABLES + "/" + tableId + "/merge";
   MergeInfo info = new MergeInfo();
   if (ZooReaderWriter.getInstance().exists(path)) {
    byte[] data = ZooReaderWriter.getInstance().getData(path, new Stat());
    DataInputBuffer in = new DataInputBuffer();
    in.reset(data, data.length);
    info.readFields(in);
   }
   System.out.println(String.format("%25s  %10s %10s %s", table, info.state, info.operation, info.range));
  }
 }
}

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

public static void main(String[] args) throws Exception {
  ClientOpts opts = new ClientOpts();
  opts.parseArgs(MergeStats.class.getName(), args);

  Connector conn = opts.getConnector();
  Map<String,String> tableIdMap = conn.tableOperations().tableIdMap();
  for (Entry<String,String> entry : tableIdMap.entrySet()) {
   final String table = entry.getKey(), tableId = entry.getValue();
   String path = ZooUtil.getRoot(conn.getInstance().getInstanceID()) + Constants.ZTABLES + "/"
     + tableId + "/merge";
   MergeInfo info = new MergeInfo();
   if (ZooReaderWriter.getInstance().exists(path)) {
    byte[] data = ZooReaderWriter.getInstance().getData(path, new Stat());
    DataInputBuffer in = new DataInputBuffer();
    in.reset(data, data.length);
    info.readFields(in);
   }
   System.out.println(String.format("%25s  %10s %10s %s", table, info.getState(),
     info.getOperation(), info.getExtent()));
  }
 }
}

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

public MergeInfo getMergeInfo(Text tableId) {
 synchronized (mergeLock) {
  try {
   String path = ZooUtil.getRoot(instance.getInstanceID()) + Constants.ZTABLES + "/" + tableId.toString() + "/merge";
   if (!ZooReaderWriter.getInstance().exists(path))
    return new MergeInfo();
   byte[] data = ZooReaderWriter.getInstance().getData(path, new Stat());
   DataInputBuffer in = new DataInputBuffer();
   in.reset(data, data.length);
   MergeInfo info = new MergeInfo();
   info.readFields(in);
   return info;
  } catch (KeeperException.NoNodeException ex) {
   log.info("Error reading merge state, it probably just finished");
   return new MergeInfo();
  } catch (Exception ex) {
   log.warn("Unexpected error reading merge state", ex);
   return new MergeInfo();
  }
 }
}

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

public MergeInfo getMergeInfo(String tableId) {
 synchronized (mergeLock) {
  try {
   String path = ZooUtil.getRoot(getInstance().getInstanceID()) + Constants.ZTABLES + "/"
     + tableId + "/merge";
   if (!ZooReaderWriter.getInstance().exists(path))
    return new MergeInfo();
   byte[] data = ZooReaderWriter.getInstance().getData(path, new Stat());
   DataInputBuffer in = new DataInputBuffer();
   in.reset(data, data.length);
   MergeInfo info = new MergeInfo();
   info.readFields(in);
   return info;
  } catch (KeeperException.NoNodeException ex) {
   log.info("Error reading merge state, it probably just finished");
   return new MergeInfo();
  } catch (Exception ex) {
   log.warn("Unexpected error reading merge state", ex);
   return new MergeInfo();
  }
 }
}

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

if (zoo.exists(monitorPath)) {
 byte[] data = zoo.getData(monitorPath, null);
 } else if (!zoo.exists(monitorLockPath)) {
 if (!zoo.exists(monitorLockPath)) {

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

if (zoo.exists(monitorPath)) {
 byte[] data = zoo.getData(monitorPath, null);
 } else if (!zoo.exists(monitorLockPath)) {
 if (!zoo.exists(monitorLockPath)) {

内容来源于网络，如有侵权，请联系作者删除！

ZooReaderWriter

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com