protected void init()

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");
        }