作者热门文章
- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.apache.helix.manager.zk.ZkBaseDataAccessor.setChildren()
方法的一些代码示例,展示了ZkBaseDataAccessor.setChildren()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkBaseDataAccessor.setChildren()
方法的具体详情如下:
包路径:org.apache.helix.manager.zk.ZkBaseDataAccessor
类名称: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;
本文整理了Java中org.apache.helix.manager.zk.ZkBaseDataAccessor.setChildren()方法的一些代码示例,展示了ZkBaseDataAccesso
我是一名优秀的程序员,十分优秀!