com.twitter.distributedlog.metadata.ZkMetadataResolver.resolve()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-13 11:07:34 27 4

public static BKDLConfig resolveDLConfig(ZooKeeperClient zkc, URI uri) throws IOException {
  DLConfig dlConfig = cachedDLConfigs.get(uri);
  if (dlConfig == null) {
    dlConfig = (new ZkMetadataResolver(zkc).resolve(uri)).getDLConfig();
    DLConfig oldDLConfig = cachedDLConfigs.putIfAbsent(uri, dlConfig);
    if (null != oldDLConfig) {
      dlConfig = oldDLConfig;
    }
  }
  assert (dlConfig instanceof BKDLConfig);
  return (BKDLConfig)dlConfig;
}

@Test(timeout = 60000)
public void testResolveFailures() throws Exception {
  // resolve unexisted path
  try {
    resolver.resolve(createURI("/unexisted/path"));
    fail("Should fail if no metadata resolved.");
  } catch (IOException e) {
    // expected
  }
  // resolve existed unbound path
  Utils.zkCreateFullPathOptimistic(zkc, "/existed/path", new byte[0],
      ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
  try {
    resolver.resolve(createURI("/existed/path"));
    fail("Should fail if no metadata resolved.");
  } catch (IOException e) {
    // expected
  }
}

@Test(timeout = 60000)
public void testResolve() throws Exception {
  DLMetadata dlMetadata = DLMetadata.create(bkdlConfig);
  dlMetadata.create(createURI("/messaging/distributedlog-testresolve"));
  DLMetadata dlMetadata2 = DLMetadata.create(bkdlConfig2);
  dlMetadata2.create(createURI("/messaging/distributedlog-testresolve/child"));
  assertEquals(dlMetadata,
      resolver.resolve(createURI("/messaging/distributedlog-testresolve")));
  assertEquals(dlMetadata2,
      resolver.resolve(createURI("/messaging/distributedlog-testresolve/child")));
  assertEquals(dlMetadata2,
      resolver.resolve(createURI("/messaging/distributedlog-testresolve/child/unknown")));
  Utils.zkCreateFullPathOptimistic(zkc, "/messaging/distributedlog-testresolve/child/child2", new byte[0],
      ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
  assertEquals(dlMetadata2,
      resolver.resolve(createURI("/messaging/distributedlog-testresolve/child/child2")));
}

27 4 0

• java - maven : Failed to install metadata project Could not parse metadata maven-metadata-local. xml:开始标记之前只允许空白内容

  当我尝试构建刚从 SVN 下载的项目时遇到此错误。 Failed to execute goal org.apache.maven.plugins:maven-install-plugin:2.4:i

• metadata - jclouds : how do I update metadata for an existing blob?

  我在 Rackspace 的云文件中有几千个 blob，我需要为其更新内容类型。但是，我不知道如何使用 jclouds API 做到这一点。 如何更新现有 blob 上的元数据？ 最佳答案 假设您已经

• metadata - 为什么 Kotlin 在 Kotlin 类文件中保存 MetaData？

  我们将 Java 文件转换为 Kotlin 文件，然后编译为类文件。生成的类比原始 Java 类文件大。在 Kotlin 类文件中，我们在每个类中都找到了元数据。为什么 Kotlin 会存储这些元数据

• go - metadata.FromOutgoingContext 和 metadata.FromIncomingContext 有什么区别？

  如果您在一个中间件中，它既接收 context 又可能将一些数据附加到 context 以将其发送到下一个拦截器，那么两者中的哪一个应该调用方法，即 metadata.FromOutgoingCont

• metadata - Keycloak SAML 适配器 : how to export SP XML metadata?

  部署后 Keycloak 3.4 SAML adapter (例如 tomcat 阀)，我正在寻找正确的方法来获取从证书和服务 URL 生成的 SP XML 元数据文件。 关于exporting Ke

• php - MySQL 上的\Zend\Db\Metadata\Metadata 速度很慢

  使用 Zend Framework 2 和 MySQL 从表中检索元数据(getConstraints() 或 getColumns())非常慢。有解决办法吗？ 最佳答案 Mysql 从信息模式检索数

• elasticsearch - 无法将加入请求发送给Elasticsearch中的主节点，未知NamedWriteable [org.elasticsearch.cluster.metadata.MetaData $ Custom] [许可证]]

  我们有一个运行时间很长的单节点ELK集群(主服务器/数据)。我决定添加其他数据节点。但是我在数据节点上收到以下错误 30.X.XXX}{172.30.X.XXX:9300}{ml.enabled=tr

• php - Symfony Make :Migration : The metadata storage is not up to date,请运行sync-metadata-storage命令修复此问题

  每当我尝试使用命令行进行迁移时，我都会不断遇到此问题:php bin/console make:migration甚至doctrine:migration status当我尝试doctrine:mig

• jsf - 元数据组件需要嵌套在 f :metadata tag. 建议:将必要的组件包含在 中

  我浏览了不同的来源，例如: Error saying I need to use f:metadata even though I do http://docs.oracle.com/javaee/7

• ios - iCloud 和核心数据错误(无处不在 : Didn't get baseline metadata back from metadata url)

  我在尝试让 iCloud 与我的应用程序一起工作时遇到了一些麻烦。我尝试按照 Tim Roadley 的示例 here ，但每当通过 Xcode 启动应用程序时，仍然会显示下面的日志(同步确实可以短暂

• ruby - 无需 Chef 或 Knife 从 metadata.rb 生成 metadata.json

  我正在开发一个将与 Chef 交互的程序。我想阅读元数据以查找依赖项以及名称等其他信息，但不应将 Chef 安装在运行它的机器上。我认为最好的方法是将 metadata.rb 翻译成 metadata

• java.lang.NoSuchMethodError : org. neo4j.ogm.session.SessionFactory.metaData()Lorg/neo4j/ogm/MetaData;

  这是我在 PersistenceContext.java 中的代码 package yuzhaoLiu.project.testNeo4j; import org.neo4j.ogm.config.C

• metadata - 在游戏功能的智能合约中获取代币元数据

  上下文 我正在开发我的第一个使用智能合约的游戏，我有一些问题。 在我的游戏中，我有角色和卡片，两个玩家将使用一个角色和 10 张卡片互相决斗。 为此，没问题:所有玩家和卡牌元数据都存储在 IPFS 存

• metadata - 通过架构优化的博客文章

  对于使用Rich Snippets优化HTML的这些方法，我还是很陌生。我不确定以下每个列表项有什么区别: http://schema.org/Article http://schema.org/Bl

• metadata - 开源元数据管理工具

  就目前而言，这个问题不适合我们的问答形式。我们希望答案得到事实、引用或专业知识的支持，但这个问题可能会引起辩论、争论、投票或扩展讨论。如果您觉得这个问题可以改进并可能重新打开，visit the he

• metadata - 面部标记信息和照片元数据

  是否有一种标准方法可以从/向照片元数据中读取/写入面部标签？ 我可以用它从流行的照片管理器导入面部标记信息吗？ 最佳答案 是的。 元数据工作组(即 Adob​​e、Microsoft、Sony、Nok

• metadata - 使用webrtc和文本轨道传递与视频帧同步的实时元数据

  我正在使用WebRTC(Win C++ native 客户端)向对等方(托管在Chrome中)广播实时视频。 目标:沿每个视频帧发送元数据(帧级别的元数据更改)。 是否可以在文本轨道内发送元数据以供对

• metadata - 使用条件随机字段进行命名实体识别

  什么是条件随机字段？ 条件随机字段如何准确地将专有名称标识为人，组织或在结构化或非结构化文本中的位置？ 例如:此产品由StackOverFlow Inc.订购。 条件随机字段如何将StackOverF

• metadata - 实例环境变量

  我有几个 Google Compute Engine 实例，并在每个实例上设置了实例元数据，假设这些在实例本身作为环境变量可用，但它们没有出现。然后我读了 here我需要查询元数据服务器以获取此数据，

• metadata - 是否有用于网站内容评级的元标记？

  我的一位客户说，她注意到她的网站在一家杂货店的 wifi 咖啡馆被屏蔽了。它不包含任何丑闻——它只是一个旅游博客。它说限制的原因是禁止类别“未评级”。 是否有某种方法可以对网页内容进行评级，使其不会被