本文整理了Java中org.apache.helix.ZNRecord.setMapFields()
方法的一些代码示例,展示了ZNRecord.setMapFields()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZNRecord.setMapFields()
方法的具体详情如下:
包路径:org.apache.helix.ZNRecord
类名称: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);
内容来源于网络,如有侵权,请联系作者删除!