com.addthis.hydra.job.store.ZookeeperDataStore.getChild()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-13 12:36:00 28 4

@Override
public Map<String, String> getAllChildren(String path) {
  Map<String, String> rv = new HashMap<>();
  List<String> children = getChildrenNames(path);
  if (children != null) {
    for (String child : children) {
      try {
        rv.put(child, getChild(path, child));
      } catch (Exception ex) {
        log.warn("Failed to fetch child " + child + " of " + path + ": " + ex, ex);
      }
    }
  }
  return rv;
}

/**
   * Write some children to a specified location. Make sure their respective data is held intact, and that the list
   * of children updates correctly after nodes are added or deleted.
   */
  @Test public void crudChildren() throws Exception {
    String savePath = "/other/path";
    try {
      String c1 = "child1";
      String c2 = "child2";
      spawnDataStore.delete(savePath);
      spawnDataStore.putAsChild(savePath, c1, "data1");
      spawnDataStore.putAsChild(savePath, c1, "data1_updated");
      spawnDataStore.putAsChild(savePath, c2, "data2");
      Set<String> bothChildren = Sets.newHashSet(spawnDataStore.getChildrenNames(savePath));
      assertEquals("should get correct children", bothChildren, Sets.newHashSet(c1, c2));
      assertEquals("should get updated value for c1", "data1_updated", spawnDataStore.getChild(savePath, c1));
      spawnDataStore.deleteChild(savePath, c2);
      Set<String> oneChild = Sets.newHashSet(spawnDataStore.getChildrenNames(savePath));
      assertEquals("should get new correct children", oneChild, Sets.newHashSet(c1));
      assertEquals("c1 should be intact", "data1_updated", spawnDataStore.getChild(savePath, c1));
      spawnDataStore.delete(savePath);
      assertNull("should get no children", spawnDataStore.getChildrenNames(savePath));
    } finally {
      spawnDataStore.delete(savePath);
    }
  }
}

28 4 0

• fb-hydra - 禁用 hydra 的文件输出

  我正在使用 hydra记录实验的超参数。 @hydra.main(config_name="config", config_path="../conf") def evaluate_experimen

• fb-hydra - 使用显式嵌套专门化 Hydra 配置

  我想拥有: conf/ ├── config.yaml ├── data │   └── data.yaml ├── render │   └── renderer.yaml ├── storage

• javascript - Api 平台 - Hydra - 访问 Hydra :member with javascript

  我遇到了无法解决的问题。我需要用 javascript 打印出响应对象，但我不知道该怎么做。我有这样的回应。这个: { "@context": "/contexts/Client", "@id

• python-3.x - 如何在不使用 @hydra.main() 的情况下获取 Hydra 配置

  假设我们有以下设置(从 Hydra docs 复制并缩短): 配置文件:config.yaml db: driver: mysql user: omry pass: secret Pyth

• mpi - Hydra MPI的最佳进步是什么

  我正在研究MPICH2随附的新流程管理器，但是直到现在我仍无法弄清楚此实现的重大进展，有人知道一个很好的教程或有什么经验吗？ argonne Wiki太简单了:http://wiki.mcs.anl.

• python - 与使用常规配置文件相比，Hydra 有哪些优势

  我想知道使用 Hydra 管理我的配置文件有什么好处，与直接加载 .yaml 配置文件(使用 import yaml)相比？ 最佳答案 TL;博士 如果您正在处理一个有许多可配置参数的项目，那么确实使

• python - 如何从脚本中覆盖 hydra 工作目录？

  我知道我可以通过设置 hydra.run.dir=XXX 来更改配置中的工作目录从命令行。 但是如何在不使用 CLI 参数的情况下从脚本中正确执行此操作，甚至将日志保存在我设置的目录中？ 此代码不起作

• linux - Hydra http 连接失败

  我想检查我的页面只有一个ip没有主机名(http://ip.ip.ip.ip/dologin.htm) 现在我想检查它是否来自 hydra。 我尝试的是: hydra -l admin -p adm

• python - 使用 hydras 定义结构数组

  我正在使用 hydras将我的 C 结构转换为 python 结构，以便能够使用 pyserial 在运行我的 C 代码和我的 python 代码的嵌入式设备之间进行通信。 我的 C 结构如下所示:

• com.addthis.hydra.mq.ZkMessageConsumer类的使用及代码示例

  本文整理了Java中com.addthis.hydra.mq.ZkMessageConsumer类的一些代码示例，展示了ZkMessageConsumer类的具体用法。这些代码示例主要来源于Githu

• angularjs - JSON-LD+Hydra 链接发现

  我一直在思考如何根据 HATEOAS 原则使用 JSON-LD 来驱动应用程序。 例如，我可以有一个简单的入口点对象，它定义了一个链接: { "@context": { "users":

• python - 从用 hydra.main() 修饰的函数返回配置

  是否可以从@hydra.main 装饰器下的函数中将配置对象作为字典获取？ 我试过这样的事情，但它返回 None @hydra.main(config_path="conf", config_name

• python - MLFlow 和 Hydra 一起使用会导致崩溃

  我正在尝试将 Hydra 与 MLFlow 结合使用，因此我编写了最低限度的脚本以查看它们是否一起工作(导入等)。两者都可以正常工作，但是当放在一起时，我得到了一个奇怪的结果。 我有下面的脚本: im

• macos - hydra 目标 ssh 不支持密码认证

  我正在使用从 tar 文件下载和编译的 Hydra v8.1。我已经设法解决了 libssh 支持的标准问题，现在当我尝试在 SSH 服务器上进行攻击(我认为这称为字典攻击)时，指定以下命令后: hy

• java - JSON-LD文档+Hydra Core生成Java代码

  是否有一个工具可以为 JSON-LD 的 RESTful 服务生成骨架，该服务具有使用 hydra 定义的操作。例如下面的例子，假设我有一个 Java 类 Present Person，构建一个逆向工

• linux - 安装支持 openssl 的 hydra

  当我尝试使用 ./configure 从源代码安装 hydra 时，出现以下消息: Checking for openssl (libssl, libcrypto, ssl.h, sha.h) ..

• com.addthis.hydra.job.store.ZookeeperDataStore类的使用及代码示例

  本文整理了Java中com.addthis.hydra.job.store.ZookeeperDataStore类的一些代码示例，展示了ZookeeperDataStore类的具体用法。这些代码示例主

• go - hydra - 使用 curl 创建策略失败，范围无效

  我已成功配置 ory/hydra OAUTH 服务器，它似乎运行良好。但是，我正在尝试使用“curl”而不是提供的 CLI 创建策略，但遇到错误: {"error":{"code":500,"mess

• docker - 如何将配置文件推送到新的 oryd/hydra docker 镜像？

  我正在使用 oryd/hydra docker 镜像:https://hub.docker.com/r/oryd/hydra为了使用我自己的配置构建自定义图像。 我确实创建了一个自定义目录: mkdi

• mpiexec.Hydra - 如何在 Hydra_pmi_proxy 位置不同的计算机上运行 MPI 进程？

  我正在尝试使用 MPICH 在两台机器的集群上运行一个简单的 MPI 程序。然而，一个运行 Fedora 17，另一个运行 Debian Squeeze - 不一定是问题，但问题是这两个发行版将其 m