public void setup()

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