public void setup()

in src/main/java/org/apache/flink/benchmark/full/PojoSerializationBenchmark.java [83:114]


    public void setup() throws IOException {
        pojo =
                new SerializationFrameworkMiniBenchmarks.MyPojo(
                        0,
                        "myName",
                        new String[] {"op1", "op2", "op3", "op4"},
                        new SerializationFrameworkMiniBenchmarks.MyOperation[] {
                            new SerializationFrameworkMiniBenchmarks.MyOperation(1, "op1"),
                            new SerializationFrameworkMiniBenchmarks.MyOperation(2, "op2"),
                            new SerializationFrameworkMiniBenchmarks.MyOperation(3, "op3")
                        },
                        1,
                        2,
                        3,
                        "null");
        avroPojo =
                new org.apache.flink.benchmark.avro.MyPojo(
                        0,
                        "myName",
                        Arrays.asList("op1", "op2", "op3", "op4"),
                        Arrays.asList(
                                new org.apache.flink.benchmark.avro.MyOperation(1, "op1"),
                                new org.apache.flink.benchmark.avro.MyOperation(2, "op2"),
                                new org.apache.flink.benchmark.avro.MyOperation(3, "op3")),
                        1,
                        2,
                        3,
                        "null");
        pojoBuffer = new ByteArrayInputStream(write(pojoSerializer, pojo));
        avroBuffer = new ByteArrayInputStream(write(avroSerializer, avroPojo));
        kryoBuffer = new ByteArrayInputStream(write(kryoSerializer, pojo));
    }