in src/main/java/org/apache/flink/benchmark/full/SerializationFrameworkAllBenchmarks.java [194:223]
protected void init() {
super.init();
if (myPojoSchema == null) {
this.myPojoSchema = new Schema.Parser().parse(schemaString);
}
Schema myOperationSchema =
myPojoSchema.getField("operations").schema().getElementType();
template = new GenericData.Record(myPojoSchema);
template.put("id", 0);
template.put("name", "myName");
template.put("operationName", Arrays.asList("op1", "op2", "op3", "op4"));
GenericData.Record op1 = new GenericData.Record(myOperationSchema);
op1.put("id", 1);
op1.put("name", "op1");
GenericData.Record op2 = new GenericData.Record(myOperationSchema);
op2.put("id", 2);
op2.put("name", "op2");
GenericData.Record op3 = new GenericData.Record(myOperationSchema);
op3.put("id", 3);
op3.put("name", "op3");
template.put("operations", Arrays.asList(op1, op2, op3));
template.put("otherId1", 1);
template.put("otherId2", 2);
template.put("otherId3", 3);
template.put("nullable", "null");
}