org.apache.samza.zk.ZkJobCoordinator.getPartitionCountMonitor()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-14 20:35:31 26 4

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

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

26 4 0

• zk - zk 中的右边空格

  我创建了一个带有列表框和按钮的网页，问题是当页面加载时，两个组件的右侧都会出现一个空白区域，但是如果调整页面大小，这些空白区域就会消失。

• zk - 自定义 ZK 图表中的特定列

  我正在使用 ZK 图表进行项目使用 MVC 方法，我想做的就是更改背景或向特定列添加指南(具有不同颜色)，例如索引为 3 的列:我想要实现的目标 这是我的图表: 这是我想要的，在索引为 3 的列中使用

• javascript - zk zAu.send 函数 - org.zkoss.zk.ui.event.MouseEvent 无法转换为 org.zkoss.zk.ui.event.ForwardEvent

  我正在集成 jquery 和 zk 项目。我的目标是将值从 js/jquery 端传递到 java 端，但徒劳无功。这是我引用的代码:use zAu to send data from client

• zk - 无法在 ZK 框架中创建自定义 UI 组件

  尝试通过 ZK 6.0.1 Component Development Essentials 创建自定义 UI 组件。尝试使用自定义组件时，日志中总是出现错误“http://localhost:808

• zk - 如何获取 zk zhtml url 参数？

  我正在使用 Zk 框架并尝试从 zhtml 页面获取 url 参数。我试过: Executions.getCurrent().getParameter("param"); 尽管我在客户端尝试了 zsc

• performance - zk vs gwt zk 请求太多

  您好，我正在尝试比较 zk 和 gwt 的性能。 在我的比较中，如果框架本身将一些代码转换为 js 就可以了(比如 gwt)，我不能自己编写任何 javascript，但我不能自己编写 js 在以上述

• java - zk:当 zk 组件被销毁/分离时如何通知监听器

  当 ZK 组件被销毁或分离时，是否有可能通知监听器？ 我希望不同的组件组合器通过事件队列进行通信。为此，我将这些组件的监听器订阅到事件队列。现在我需要知道组件或其 Composer 何时被销毁才能取消

• zk - 使用 zk 从 session 中获取值(value)

  我用 struts 1 配置了 zk。我创建了一个列表并在 session 中设置。 List nameList = new ArrayList(); nameList.add( "xxx" ); n

• javascript - ZK:如何使用 JavaScript 在客户端填充 zk 组合框

  我想基于 zk 组合框制作新的 zk 组件，以保存以前输入的历史记录。我想将这些先前的输入存储在客户端的 localStorage 中。所以我必须使用 JavaScript 在客户端填充组合框，但不知

• zk - 有什么方法可以将 ZK colorBox 的 RGB 转换为 HexaDecimal

  我在我的应用程序中使用 ZK colorbox，我想将 Colorbox 的 getRGB() 方法的 RGB 值转换为十六进制。 我有什么办法可以做到这一点吗？ 最佳答案 您可以使用 org.zko

• spring - ZK - 将 Spring bean 直接注入(inject) ZK bean

  是否可以将 Spring bean 直接注入(inject)到 ZK backing bean 中？ 在教程中，例如 this我只找到了一个示例，其中应用程序上下文是从复杂的 Web 应用程序中手动提

• org.apache.ignite.spi.discovery.zk.internal.ZookeeperClient.zk()方法的使用及代码示例

  本文整理了Java中org.apache.ignite.spi.discovery.zk.internal.ZookeeperClient.zk()方法的一些代码示例，展示了ZookeeperClie

• java - 使用 ZK studio 在 Eclipse Juno 上创建 ZK 项目

  我安装了 Eclipse Juno 并添加了 ZK Studio 插件。我的Java JDK是1.5。 但是，当我尝试创建新项目时，出现如下错误: The selected wizard could

• java - ZK 代码返回 org.zkoss.zk.ui.UiException 和 java.lang.NumberFormatException？

  我收到以下异常 org.zkoss.zk.ui.UiException 和 java.lang.NumberFormatException。有人可以帮忙吗？我的堆栈跟踪如下: Nov 08, 2013

• java - 如何设置 Zk Sessions (org.zkoss.zk.ui)，以便我可以对扩展 GenericForwardComposer 的 Controller 类进行单元测试

  我正在尝试对现有的 ZK Controller 进行单元测试，并且我想找到一种方法来在对我的 Controller 进行单元测试时处理如下调用， Sessions.getCurrent().setAt

• apache-spark - 如何触发提交到 ZooKeeper 管理的 Mesos 集群(给出 java.net.UnknownHostException : zk for mesos://zk://master URL)?

  我正在运行 Spark 2.0.2 和 Mesos 0.28.2。 我正在尝试向 Spark 提交一个应用程序，使用 ZooKeeper 管理的 Mesos 集群作为主节点: $SPARK_HOME/

• mvvm - ZK Hflex在使用MVVM并包含方法时不起作用

  当我在MVVM方法的包含页面中使用Hflex属性时，它不起作用。 当我在另一个页面中包含某个页面时，就会发生此问题，并且此页面的组件的大小由hflex属性控制。我已经尝试过在父窗口加载时使用inval

• spring - zk-grails与Spring安全性集成

  我在带有zk-grails插件的grails 2.3.11中有一个应用程序。当我执行Spring Security Core集成进行身份验证时，zul页面会停止响应，并出现以下错误:“服务器暂时无法使

• java - ZK - 检查元素是否具有焦点

  ZK支持检查元素是否有焦点吗？ HtmlBasedComponent 具有 focus() 和 setFocus(boolean) 来设置焦点..但我没有看到任何 getFocus(). 具体来说，我

• java - ZK - 将用户重定向回上一页

  关于如何干净、稳健地将用户重定向回上一页有什么想法吗？ 如果上一页位于应用程序本身内，我只关心将它们重定向回来。我曾考虑过在用户的 session 中存储某种 DIY 历史记录，但这似乎并不干净或健壮