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

ZkJobCoordinator.getPartitionCountMonitor介绍

暂无

代码示例

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

@Override
 public void onBecomingLeader() {
  LOG.info("ZkJobCoordinator::onBecomeLeader - I became the leader");
  metrics.isLeader.set(true);
  zkUtils.subscribeToProcessorChange(new ProcessorChangeHandler(zkUtils));
  if (!new StorageConfig(config).hasDurableStores()) {
   // 1. Stop if there's a existing StreamPartitionCountMonitor running.
   if (streamPartitionCountMonitor != null) {
    streamPartitionCountMonitor.stop();
   }
   // 2. Start a new instance of StreamPartitionCountMonitor.
   streamPartitionCountMonitor = getPartitionCountMonitor();
   streamPartitionCountMonitor.start();
  }
  debounceTimer.scheduleAfterDebounceTime(ON_PROCESSOR_CHANGE, debounceTimeMs, ZkJobCoordinator.this::doOnProcessorChange);
 }
}

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

@Test
public void testShouldStartPartitionCountMonitorOnBecomingLeader() {
 ZkKeyBuilder keyBuilder = Mockito.mock(ZkKeyBuilder.class);
 ZkClient mockZkClient = Mockito.mock(ZkClient.class);
 when(keyBuilder.getJobModelVersionBarrierPrefix()).thenReturn(TEST_BARRIER_ROOT);
 ZkUtils zkUtils = Mockito.mock(ZkUtils.class);
 when(zkUtils.getKeyBuilder()).thenReturn(keyBuilder);
 when(zkUtils.getZkClient()).thenReturn(mockZkClient);
 when(zkUtils.getJobModel(TEST_JOB_MODEL_VERSION)).thenReturn(new JobModel(new MapConfig(), new HashMap<>()));
 ScheduleAfterDebounceTime mockDebounceTimer = Mockito.mock(ScheduleAfterDebounceTime.class);
 ZkJobCoordinator zkJobCoordinator = Mockito.spy(new ZkJobCoordinator("TEST_PROCESSOR_ID", new MapConfig(), new NoOpMetricsRegistry(), zkUtils));
 StreamPartitionCountMonitor monitor = Mockito.mock(StreamPartitionCountMonitor.class);
 zkJobCoordinator.debounceTimer = mockDebounceTimer;
 zkJobCoordinator.streamPartitionCountMonitor = monitor;
 when(zkJobCoordinator.getPartitionCountMonitor()).thenReturn(monitor);
 ZkJobCoordinator.LeaderElectorListenerImpl listener = zkJobCoordinator.new LeaderElectorListenerImpl();
 listener.onBecomingLeader();
 Mockito.verify(monitor).start();
}