org.apache.helix.ZNRecord.setMapFields()方法的使用及代码示例

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

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

ZNRecord.setMapFields介绍

[英]Set all fields whose values are key, value properties
[中]

代码示例

代码示例来源:origin: apache/incubator-pinot

public ZNRecord toZNRecord() {
 ZNRecord record = new ZNRecord(_tableNameWithType);
 record.setListFields(_parentGroupToChildrenGroupsMap);
 Map<String, Map<String, String>> groupToSegmentsMap = new HashMap<>();
 for (Map.Entry<Integer, Map<String, List<String>>> entry : _levelToGroupToSegmentsMap.entrySet()) {
  String key = LEVEL_KEY_PREFIX + entry.getKey();
  Map<String, String> groupSegmentsForLevel = new HashMap<>();
  for (Map.Entry<String, List<String>> groupEntry : entry.getValue().entrySet()) {
   String groupId = groupEntry.getKey();
   String segments = String.join(SEGMENT_DELIMITER, groupEntry.getValue());
   groupSegmentsForLevel.put(groupId, segments);
  }
  groupToSegmentsMap.put(key, groupSegmentsForLevel);
 }
 record.setMapFields(groupToSegmentsMap);
 return record;
}

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

/**
 * Set a group of heath statistics, grouped by the statistic
 * @param healthFields a map of statistic name, the corresponding entity, and the value
 */
public void setHealthFields(Map<String, Map<String, String>> healthFields) {
 _record.setMapFields(healthFields);
}

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

/**
 * Set a group of heath statistics, grouped by the statistic
 * @param healthFields a map of statistic name, the corresponding entity, and the value
 */
public void setHealthFields(Map<String, Map<String, String>> healthFields) {
 _record.setMapFields(healthFields);
}

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

result.setMapFields(idealStateMap);
return result;

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

result.setMapFields(idealStateMap);
return result;

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

record.setSimpleFields(simpleFields);
 record.setListFields(listFields);
 record.setMapFields(mapFields);
 record.setRawPayload(rawPayload);
} catch (Exception e) {

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

record.setSimpleFields(simpleFields);
 record.setListFields(listFields);
 record.setMapFields(mapFields);
 record.setRawPayload(rawPayload);
} catch (Exception e) {

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

record.setMapFields(partitionReport);

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

record.setMapFields(partitionReport);

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

idealState.getRecord().setListFields(newIdealState.getListFields());
idealState.getRecord().setMapFields(newIdealState.getMapFields());
idealState.getRecord().setMapFields(newIdealState.getMapFields());

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

idealState.getRecord().setListFields(newIdealState.getListFields());
idealState.getRecord().setMapFields(newIdealState.getMapFields());
idealState.getRecord().setMapFields(newIdealState.getMapFields());

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

dupMsg.getRecord().setSimpleFields(sourceMsg.getRecord().getSimpleFields());
dupMsg.getRecord().setListFields(sourceMsg.getRecord().getListFields());
dupMsg.getRecord().setMapFields(sourceMsg.getRecord().getMapFields());
accessor.setProperty(dupMsg.getKey(accessor.keyBuilder(), dupMsg.getTgtName()), dupMsg);
Thread.sleep(1000);

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

targetExternalView.getRecord().setMapFields(intermediateAssignment);
needPersist = true;

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

targetExternalView.getRecord().setMapFields(intermediateAssignment);
needPersist = true;

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

_record.setMapFields(mapFields);

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

_record.setMapFields(mapFields);

相关文章