gpt4 book ai didi

io.pravega.segmentstore.server.host.ZKSegmentContainerMonitor.()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-13 10:59:32 27 4
gpt4 key购买 nike

本文整理了Java中io.pravega.segmentstore.server.host.ZKSegmentContainerMonitor.<init>()方法的一些代码示例,展示了ZKSegmentContainerMonitor.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZKSegmentContainerMonitor.<init>()方法的具体详情如下:
包路径:io.pravega.segmentstore.server.host.ZKSegmentContainerMonitor
类名称:ZKSegmentContainerMonitor
方法名:<init>

ZKSegmentContainerMonitor.<init>介绍

[英]Creates an instance of ZKSegmentContainerMonitor.
[中]创建ZKSectionContainerMonitor的实例。

代码示例

代码示例来源:origin: pravega/pravega

/**
 * Creates a new instance of the ZKSegmentContainerManager class.
 *
 * @param containerRegistry      The SegmentContainerRegistry to manage.
 * @param zkClient               ZooKeeper client.
 * @param pravegaServiceEndpoint Pravega service endpoint details.
 * @param executor               Executor service for running async operations.
 */
ZKSegmentContainerManager(SegmentContainerRegistry containerRegistry, CuratorFramework zkClient,
             Host pravegaServiceEndpoint, ScheduledExecutorService executor) {
  Preconditions.checkNotNull(containerRegistry, "containerRegistry");
  Preconditions.checkNotNull(zkClient, "zkClient");
  this.host = Preconditions.checkNotNull(pravegaServiceEndpoint, "pravegaServiceEndpoint");
  this.cluster = new ClusterZKImpl(zkClient, ClusterType.HOST);
  this.containerMonitor = new ZKSegmentContainerMonitor(containerRegistry, zkClient, pravegaServiceEndpoint, executor);
}

代码示例来源:origin: pravega/pravega

private ZKSegmentContainerMonitor createContainerMonitor(
    SegmentContainerRegistry registry, CuratorFramework zkClient) {
  return new ZKSegmentContainerMonitor(registry, zkClient, PRAVEGA_SERVICE_ENDPOINT, executorService());
}

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com