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

ZkBarrierForVersionUpgrade.expire介绍

[英]Expires the barrier version by marking it as TIMED_OUT
[中]通过将屏障版本标记为超时，使其过期

代码示例

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

@Override
public void onBarrierCreated(String version) {
 // Start the timer for rebalancing
 startTime = System.nanoTime();
 metrics.barrierCreation.inc();
 if (leaderElector.amILeader()) {
  debounceTimer.scheduleAfterDebounceTime(barrierAction, (new ZkConfig(config)).getZkBarrierTimeoutMs(), () -> barrier.expire(version));
 }
}

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

@Override
public void onBarrierCreated(String version) {
 // Start the timer for rebalancing
 startTime = System.nanoTime();
 metrics.barrierCreation.inc();
 if (leaderElector.amILeader()) {
  debounceTimer.scheduleAfterDebounceTime(barrierAction, (new ZkConfig(config)).getZkBarrierTimeoutMs(), () -> barrier.expire(version));
 }
}

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

@Override
public void onBarrierCreated(String version) {
 // Start the timer for rebalancing
 startTime = System.nanoTime();
 metrics.barrierCreation.inc();
 if (leaderElector.amILeader()) {
  debounceTimer.scheduleAfterDebounceTime(barrierAction, (new ZkConfig(config)).getZkBarrierTimeoutMs(), () -> barrier.expire(version));
 }
}

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

@Override
public void onBarrierCreated(String version) {
 // Start the timer for rebalancing
 startTime = System.nanoTime();
 metrics.barrierCreation.inc();
 if (leaderElector.amILeader()) {
  debounceTimer.scheduleAfterDebounceTime(barrierAction, (new ZkConfig(config)).getZkBarrierTimeoutMs(), () -> barrier.expire(version));
 }
}

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

@Override
public void onBarrierCreated(String version) {
 // Start the timer for rebalancing
 startTime = System.nanoTime();
 metrics.barrierCreation.inc();
 if (leaderElector.amILeader()) {
  debounceTimer.scheduleAfterDebounceTime(barrierAction, (new ZkConfig(config)).getZkBarrierTimeoutMs(), () -> barrier.expire(version));
 }
}

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

@Test
public void testZkBarrierForVersionUpgradeWithTimeOut() {
 String barrierId = String.format("%s/%s", zkUtils1.getKeyBuilder().getRootPath(), RandomStringUtils.randomAlphabetic(4));
 List<String> processors = ImmutableList.of("p1", "p2", "p3");
 CountDownLatch latch = new CountDownLatch(2);
 TestZkBarrierListener listener = new TestZkBarrierListener(latch, State.TIMED_OUT);
 ZkBarrierForVersionUpgrade processor1Barrier = new ZkBarrierForVersionUpgrade(barrierId, zkUtils, listener, debounceTimer);
 ZkBarrierForVersionUpgrade processor2Barrier = new ZkBarrierForVersionUpgrade(barrierId, zkUtils1, listener, debounceTimer);
 processor1Barrier.create(BARRIER_VERSION, processors);
 processor1Barrier.join(BARRIER_VERSION, "p1");
 processor2Barrier.join(BARRIER_VERSION, "p2");
 processor1Barrier.expire(BARRIER_VERSION);
 boolean result = false;
 try {
  result = latch.await(10000, TimeUnit.MILLISECONDS);
 } catch (InterruptedException e) {
  e.printStackTrace();
 }
 assertTrue("Barrier Timeout test failed to complete within test timeout.", result);
 List<String> children = zkUtils.getZkClient().getChildren(barrierId + "/barrier_1/barrier_participants");
 State barrierState = zkUtils.getZkClient().readData(barrierId + "/barrier_1/barrier_state");
 assertEquals(State.TIMED_OUT, barrierState);
 assertNotNull(children);
 assertEquals("Unexpected barrier state. Didn't find two processors.", 2, children.size());
 assertEquals("Unexpected barrier state. Didn't find the expected members.", ImmutableList.of("p1", "p2"), children);
}

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

@Test
public void testShouldDiscardBarrierUpdateEventsAfterABarrierIsMarkedAsDone() {
 String barrierId = String.format("%s/%s", zkUtils1.getKeyBuilder().getRootPath(), RandomStringUtils.randomAlphabetic(4));
 List<String> processors = ImmutableList.of("p1", "p2");
 CountDownLatch latch = new CountDownLatch(2);
 TestZkBarrierListener listener = new TestZkBarrierListener(latch, State.DONE);
 ZkBarrierForVersionUpgrade processor1Barrier = new ZkBarrierForVersionUpgrade(barrierId, zkUtils, listener, debounceTimer);
 ZkBarrierForVersionUpgrade processor2Barrier = new ZkBarrierForVersionUpgrade(barrierId, zkUtils1, listener, debounceTimer);
 processor1Barrier.create(BARRIER_VERSION, processors);
 processor1Barrier.join(BARRIER_VERSION, "p1");
 processor2Barrier.join(BARRIER_VERSION, "p2");
 boolean result = false;
 try {
  result = latch.await(10000, TimeUnit.MILLISECONDS);
 } catch (InterruptedException e) {
  e.printStackTrace();
 }
 assertTrue("Barrier Timeout test failed to complete within test timeout.", result);
 processor1Barrier.expire(BARRIER_VERSION);
 State barrierState = zkUtils.getZkClient().readData(barrierId + "/barrier_1/barrier_state");
 assertEquals(State.DONE, barrierState);
}

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

processor2Barrier.join(BARRIER_VERSION, "p2");
processor1Barrier.expire(BARRIER_VERSION);