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

ZkMetadataResolver.resolve介绍

暂无

代码示例

代码示例来源：origin: twitter/distributedlog

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;
}

代码示例来源：origin: twitter/distributedlog

@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
  }
}

代码示例来源：origin: twitter/distributedlog

@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")));
}