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

ZkKeyBuilder.parseIdFromPath介绍

[英]Static method that helps parse the processorId substring from the ZK path Processor ID is prefixed by "processor-" and is an leaf node in ZK tree. Hence, this pattern is used to extract the processorId.
[中]帮助从ZK路径处理器ID解析processorId子字符串的静态方法以“Processor-”为前缀，是ZK树中的叶节点。因此，该模式用于提取processorId。

代码示例

代码示例来源：origin: apache/samza

@Test
public void testParseIdFromPath() {
 Assert.assertEquals(
   "1",
   ZkKeyBuilder.parseIdFromPath("/test/processors/" + "1"));
 Assert.assertNull(ZkKeyBuilder.parseIdFromPath(null));
 Assert.assertNull(ZkKeyBuilder.parseIdFromPath(""));
}

代码示例来源：origin: org.apache.samza/samza-core_2.11

int index = children.indexOf(ZkKeyBuilder.parseIdFromPath(nodePath));

代码示例来源：origin: org.apache.samza/samza-core_2.12

int index = children.indexOf(ZkKeyBuilder.parseIdFromPath(nodePath));

代码示例来源：origin: apache/samza

int index = children.indexOf(ZkKeyBuilder.parseIdFromPath(nodePath));

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

int index = children.indexOf(ZkKeyBuilder.parseIdFromPath(nodePath));

代码示例来源：origin: org.apache.samza/samza-core_2.10

int index = children.indexOf(ZkKeyBuilder.parseIdFromPath(nodePath));

代码示例来源：origin: apache/samza

@Override
 public void handleDataDeleted(String dataPath)
   throws Exception {
  String registeredIdStr = ZkKeyBuilder.parseIdFromPath(path2);
  Assert.assertNotNull(registeredIdStr);
  String predecessorIdStr = ZkKeyBuilder.parseIdFromPath(dataPath);
  Assert.assertNotNull(predecessorIdStr);
  try {
   int selfId = Integer.parseInt(registeredIdStr);
   int predecessorId = Integer.parseInt(predecessorIdStr);
   Assert.assertEquals(1, selfId - predecessorId);
  } catch (Exception e) {
   LOG.error(e.getLocalizedMessage());
  }
  count.incrementAndGet();
  electionLatch.countDown();
 }
});

代码示例来源：origin: apache/samza

@Override
 public void handleDataDeleted(String dataPath)
   throws Exception {
  String registeredIdStr = ZkKeyBuilder.parseIdFromPath(path3);
  Assert.assertNotNull(registeredIdStr);
  String predecessorIdStr = ZkKeyBuilder.parseIdFromPath(dataPath);
  Assert.assertNotNull(predecessorIdStr);
  try {
   int selfId = Integer.parseInt(registeredIdStr);
   int predecessorId = Integer.parseInt(predecessorIdStr);
   Assert.assertEquals(1, selfId - predecessorId);
  } catch (Exception e) {
   Assert.fail("Exception in LeaderElectionListener!");
  }
  count.incrementAndGet();
  electionLatch.countDown();
 }
});

代码示例来源：origin: apache/samza

int index = children.indexOf(ZkKeyBuilder.parseIdFromPath(currentPath));

代码示例来源：origin: org.apache.samza/samza-core_2.11

int index = children.indexOf(ZkKeyBuilder.parseIdFromPath(currentPath));

代码示例来源：origin: org.apache.samza/samza-core_2.12

int index = children.indexOf(ZkKeyBuilder.parseIdFromPath(currentPath));

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

int index = children.indexOf(ZkKeyBuilder.parseIdFromPath(currentPath));

代码示例来源：origin: org.apache.samza/samza-core_2.10

int index = children.indexOf(ZkKeyBuilder.parseIdFromPath(currentPath));