in timescaledb-connector/src/main/java/com/epam/deltix/timebase/connector/service/timebase/TimebaseRawMessageService.java [79:97]
private Map<String, Object> expandValues(Map<String, Object> values, String parentFieldName) {
Map<String, Object> expandedValues = new HashMap<>();
if (parentFieldName != null) {
RecordClassDescriptor classDescriptor = (RecordClassDescriptor) values.get("objectClassName");
expandedValues.put(parentFieldName + "_" + "descriptor_name", classDescriptor.getName());
}
values.forEach((name, value) -> {
String fieldName = parentFieldName == null ? name : parentFieldName + "_" + name;
if (value instanceof Map) {
expandedValues.putAll(expandValues((Map<String, Object>) value, fieldName));
} else {
expandedValues.put(fieldName, value);
}
});
return expandedValues;
}