gpt4 book ai didi

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

转载 作者:知者 更新时间:2024-03-13 21:20:03 25 4
gpt4 key购买 nike

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

ZkBaseDataAccessor.setChildren介绍

[英]async set TODO: rename to set
[中]异步设置TODO:重命名为set

代码示例

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

@Override
public boolean[] setChildren(List<String> paths, List<T> records, int options) {
 final int size = paths.size();
 List<String> serverPaths = prependChroot(paths);
 Cache<T> cache = getCache(serverPaths);
 if (cache != null) {
  try {
   cache.lockWrite();
   List<Stat> setStats = new ArrayList<Stat>();
   List<List<String>> pathsCreatedList =
     new ArrayList<List<String>>(Collections.<List<String>> nCopies(size, null));
   boolean[] success =
     _baseAccessor.set(serverPaths, records, pathsCreatedList, setStats, options);
   for (int i = 0; i < size; i++) {
    updateCache(cache, pathsCreatedList.get(i), success[i], serverPaths.get(i),
      records.get(i), setStats.get(i));
   }
   return success;
  } finally {
   cache.unlockWrite();
  }
 }
 return _baseAccessor.setChildren(serverPaths, records, options);
}

代码示例来源:origin: apache/helix

@Override
public boolean[] setChildren(List<String> paths, List<T> records, int options) {
 final int size = paths.size();
 List<String> serverPaths = prependChroot(paths);
 Cache<T> cache = getCache(serverPaths);
 if (cache != null) {
  try {
   cache.lockWrite();
   List<Stat> setStats = new ArrayList<Stat>();
   List<List<String>> pathsCreatedList =
     new ArrayList<List<String>>(Collections.<List<String>>nCopies(size, null));
   boolean[] success =
     _baseAccessor.set(serverPaths, records, pathsCreatedList, setStats, options);
   for (int i = 0; i < size; i++) {
    updateCache(cache, pathsCreatedList.get(i), success[i], serverPaths.get(i),
      records.get(i), setStats.get(i));
   }
   return success;
  } finally {
   cache.unlockWrite();
  }
 }
 return _baseAccessor.setChildren(serverPaths, records, options);
}

代码示例来源:origin: apache/helix

records.add(record);
success = extBaseAccessor.setChildren(paths, records, AccessOption.PERSISTENT);
for (int i = 0; i < 10; i++) {
 Assert.assertTrue(success[i], "Should succeed in set: " + paths.get(i));

代码示例来源:origin: apache/helix

records.add(newRecord);
success = accessor.setChildren(paths, records, AccessOption.PERSISTENT);
for (int i = 0; i < 10; i++) {
 String msgId = "msg_" + i;

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