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

x33g5p2x  于2022-02-05 转载在 其他  
字(2.7k)|赞(0)|评价(0)|浏览(86)

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

ZKHelixDataAccessor.getChildValues介绍

暂无

代码示例

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

@Deprecated
@Override
public <T extends HelixProperty> List<T> getChildValues(PropertyKey key) {
 return getChildValues(key, false);
}

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

@Deprecated
@Override
public <T extends HelixProperty> List<T> getChildValues(PropertyKey key) {
 return getChildValues(key, false);
}

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

@Override
public <T extends HelixProperty> Map<String, T> getChildValuesMap(PropertyKey key,
  boolean throwException) {
 PropertyType type = key.getType();
 String parentPath = key.getPath();
 int options = constructOptions(type);
 List<T> children = getChildValues(key, throwException);
 Map<String, T> childValuesMap = new HashMap<String, T>();
 for (T t : children) {
  childValuesMap.put(t.getRecord().getId(), t);
 }
 return childValuesMap;
}

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

@Override
public <T extends HelixProperty> Map<String, T> getChildValuesMap(PropertyKey key,
  boolean throwException) {
 PropertyType type = key.getType();
 String parentPath = key.getPath();
 int options = constructOptions(type);
 List<T> children = getChildValues(key, throwException);
 Map<String, T> childValuesMap = new HashMap<String, T>();
 for (T t : children) {
  childValuesMap.put(t.getRecord().getId(), t);
 }
 return childValuesMap;
}

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

public static String getInstancePropertiesAsString(ZkClient zkClient, String clusterName,
  PropertyKey propertyKey, MediaType mediaType) throws JsonGenerationException,
  JsonMappingException, IOException {
 zkClient.setZkSerializer(new ZNRecordSerializer());
 ZKHelixDataAccessor accessor =
   new ZKHelixDataAccessor(clusterName, new ZkBaseDataAccessor<ZNRecord>(zkClient));
 List<ZNRecord> records = HelixProperty.convertToList(accessor.getChildValues(propertyKey));
 return ObjectToJson(records);
}

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

Builder keyBuilder = accessor.keyBuilder();
List<ExternalView> extViews = accessor.getChildValues(keyBuilder.externalViews());
Assert.assertNotNull(extViews);

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

_dataAccessor.getChildValues(_keyBuilder.currentStates(_instanceName, session));

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

_dataAccessor.getChildValues(_keyBuilder.currentStates(_instanceName, session));

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

for (int i = 0; i < n; i++) {
 List<Message> msgs =
   accessor.getChildValues(keyBuilder.messages(participants[i].getInstanceName()));
 totalMsgs += msgs.size();

相关文章