in src/main/java/org/apache/flink/benchmark/full/StringSerializationBenchmark.java [84:102]
public void setup() throws IOException {
length = Integer.parseInt(lengthStr);
switch (type) {
case "ascii":
input = generate(asciiChars, length);
break;
case "russian":
input = generate(russianChars, length);
break;
case "chinese":
input = generate(chineseChars, length);
break;
default:
throw new IllegalArgumentException(type + "charset is not supported");
}
byte[] stringBytes = stringWrite();
serializedBuffer = new ByteArrayInputStream(stringBytes);
serializedStream = new DataInputViewStreamWrapper(serializedBuffer);
}