in src/main/java/com/amazonaws/mskdatagen/producer/SchemaValueResultBuilder.java [27:45]
public Pair<Schema, Object> build() {
Schema schema = buildSchema();
Object result = null;
for (List<String> keyList : this.generatedResults.keySet()) {
if (keyList.isEmpty()) {
return Pair.of(schema, this.generatedResults.get(Collections.emptyList()));
}
Object currentResult = buildConvertedObjRec(keyList, schema, 0);
if (result instanceof Struct && currentResult instanceof Struct) {
Struct currentStuct = (Struct) currentResult;
((Struct) result).put(keyList.get(0), currentStuct.get(keyList.get(0)));
} else {
result = currentResult;
}
}
return Pair.of(schema, result);
}