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