org.apache.helix.manager.zk.ZkClient.readDataAndStat()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-14 11:14:49 27 4

private ZNRecord readZkChild(String zkPath, ZkClient zkClient) {
 ZNRecord result = null;
 // read data and stat
 Stat stat = new Stat();
 ZNRecord data = zkClient.readDataAndStat(zkPath, stat, true);
 if (data != null) {
  result = data;
 } else {
  result = new ZNRecord("");
 }
 // read childrenList
 List<String> children = zkClient.getChildren(zkPath);
 if (children != null && children.size() > 0) {
  result.setSimpleField("numChildren", "" + children.size());
  result.setListField("childrenList", children);
 } else {
  result.setSimpleField("numChildren", "" + 0);
 }
 return result;
}

public static List<ZNRecord> getChildren(ZkClient client, String path) {
 // parent watch will be set by zkClient
 List<String> children = client.getChildren(path);
 if (children == null || children.size() == 0) {
  return Collections.emptyList();
 }
 List<ZNRecord> childRecords = new ArrayList<ZNRecord>();
 for (String child : children) {
  String childPath = path + "/" + child;
  Stat newStat = new Stat();
  ZNRecord record = client.readDataAndStat(childPath, newStat, true);
  if (record != null) {
   record.setVersion(newStat.getVersion());
   record.setCreationTime(newStat.getCtime());
   record.setModifiedTime(newStat.getMtime());
   childRecords.add(record);
  }
 }
 return childRecords;
}

private ZNRecord readZkDataStatAndChild(String zkPath, ZkClient zkClient) {
 ZNRecord result = null;
 // read data and stat
 Stat stat = new Stat();
 ZNRecord data = zkClient.readDataAndStat(zkPath, stat, true);
 if (data != null) {
  result = data;
 } else {
  result = new ZNRecord("");
 }
 result.setSimpleField("zkPath", zkPath);
 result.setSimpleField("stat", stat.toString());
 result.setSimpleField("numChildren", "" + stat.getNumChildren());
 result.setSimpleField("ctime", "" + new Date(stat.getCtime()));
 result.setSimpleField("mtime", "" + new Date(stat.getMtime()));
 result.setSimpleField("dataLength", "" + stat.getDataLength());
 // read childrenList
 List<String> children = zkClient.getChildren(zkPath);
 if (children != null && children.size() > 0) {
  result.setListField("children", children);
 }
 return result;
}

Assert.assertEquals((long) beanServer.getAttribute(idealStatename, "ReadBytesCounter"),
  TEST_DATA_SIZE);
zkClient.readDataAndStat(TEST_PATH, new Stat(), true);
Assert.assertEquals((long) beanServer.getAttribute(rootname, "ReadCounter"), 5);

try {
 Stat stat = new Stat();
 ZNRecord record = zkClient.<ZNRecord> readDataAndStat(path, stat, true);

27 4 0

• aws systems manager: Managed instance not appearing in the fleet manager(aws系统管理器：管理实例未出现在舰队管理器中)

  I have created a hybrid activation and then setup an ssm agent on my on-premise windows system.我创

• manage.py - manage.py 文件究竟做了什么

  我对 python/django 编程很陌生，因为我没有编程背景。我正在在线上课，我只想确切地知道 manage.py 文件的作用。我试过用谷歌搜索它，但除了在 django-admin.py 周围放

• java - "managed"取决于 "manager"结构

  我的 DependancyInject 存在结构问题。 情况 我正在为基于体素的游戏创建服务器；它是完全调制的，但相关模块有以下3个。 NetworkModule(发送和接收数据包)WorldModu

• project-management - Scrum Master "manage"如何成为失控的产品负责人？

  关闭。这个问题不满足Stack Overflow guidelines .它目前不接受答案。 想改善这个问题吗？更新问题，使其成为 on-topic对于堆栈溢出。 5年前关闭。 Improve thi

• docker - Manager Leader 和 Manager 有什么区别

  上 Docker正在编写的网站: The MANAGER STATUS column shows node participation in the Raft consensus: No value

• release-management - Release Management 2015 中的组件、工具和操作之间有什么区别？

  我正在尝试使用发布管理作为构建版本的工具，但我很难理解码件、工具和操作之间的真正区别。有人可以分解这三个概念之间的差异以及它们如何相互配合吗？ 最佳答案 由于它适用于基于代理的版本: 工具旨在提供自定

• python - pycharm Manage.py任务导入错误: No module named manage

  当尝试在远程环境中在 pycharm 中执行“run manage.py Task...”时，出现以下错误: ssh://vagrant@127.0.0.1:2222/home/vagrant/.vi

• android.bat 打开SDK Manager，SDK Manager.exe不打开

  在过去的 48 小时里，我一直在努力解决这个问题，这让我发疯了。 我的 SDK Manager.exe 闪烁一个 cmd 屏幕并在不到一秒内关闭。 经过多方搜索，我终于在调整android.bat并以

• python - 向自定义 Django management/manage.py 命令添加确认步骤

  我在 this tutorial 之后创建了以下自定义管理命令. from django.core.management.base import BaseCommand, CommandError f

• android-management-api - 请求增加 Android Management API 设备限制

  我在一家拥有 2,500 多名员工和同样多的 Android 智能手机的非营利组织工作。 近年来，我们测试了许多 EMM 产品。尽管我们只需要一些非常基本的功能，除了一两个特殊功能，但没有一个能真正赢

• google-tag-manager - Google Tag Manager 上的预览模式对我不起作用(超时)

  我已经在我的网站上安装了 Google 标签管理器，但自从新版本的 Google 标签管理器以来，我无法使用预览选项。每次我点击它时，我都会看到我的网站页面打开，但随后出现以下错误:“Tag Assi

• django 'Manager' 对象不可迭代(但代码在 manage.py shell 中有效)

  我是 django 的新手，并创建了一个与教程中描述的民意调查网站没有太大区别的应用程序。 在网站上我得到: Exception Type: TemplateSyntaxError Exception

• google-deployment-manager - google deployment manager，你能在你直接用--template调用的jinja模板中导入文件吗？

  https://cloud.google.com/deployment-manager/docs/configuration/templates/create-basic-template 我可以像这

• ms-release-management - 部署步骤期间 Microsoft Release Management 超时

  我们正在使用 Microsoft 的发布管理将我们的 Web 应用程序部署到我们的测试环境 (QA)。它是一个直接的 MVC.Net Web 应用程序。我们的构建生成一个 web 部署包，我们有一个命

• django - 如何将 "python manage.py"更改为 "./manage.py"？

  我想将 python manage.py 缩短为 ./manage.py。 这可能很简单，但我找不到答案。我在有关 django 的问题的答案之一中看到了一步一步的方法，但我没有记住。尝试在 stac

• django - 如何将 "python manage.py"更改为 "./manage.py"？

  我想将 python manage.py 缩短为 ./manage.py。 这可能很简单，但我找不到答案。我在有关 django 的问题的答案之一中看到了一步一步的方法，但我没有记住。尝试在 stac

• mysql - SSIS - MySQL 源代码 : Could not create a managed connection manager

  我正在使用安装了 SQL Server Data Tools 的 VS 2012。我有一个 ADO NET 源，它使用 .Net Providers\MySQL 数据提供程序，并试图将一些数据推送到

• Android Work Manager - Work Manager 会 100% 确保后台执行完成吗？

  根据我从文档中阅读的内容 https://developer.android.com/topic/libraries/architecture/workmanager , 它说: The task i

• android - Fragment Manager 和 Support Fragment Manager 的区别

  这两个类显然是相关的。 SupportFragmentManager 是否用于使用 FragmentTransaction 生成的 Fragments，而“常规”FragmentManager 专门用

• To display manager details if more than one manager is from same city(如果多个经理来自同一城市，则显示经理详细信息)

  我有一个桌子经理(经理ID、姓名、地址、城市、电话)。如果多个经理来自同一城市，我必须显示城市、姓名和电话详细信息。我的代码是：。但这向我展示了第一行中的一个错误，即“不是按表达式分组”。请救救我！