public void setUp()

in src/main/java/org/apache/flink/state/benchmark/HashMapStateBackendRescalingBenchmarkExecutor.java [50:68]

• 18 lines of code
• 1 McCabe index (conditional complexity)

    public void setUp() throws Exception {
        // FsStateBackend is deprecated in favor of HashMapStateBackend with setting checkpointStorage.
        HashMapStateBackend stateBackend = new HashMapStateBackend();
        Configuration benchMarkConfig = ConfigUtil.loadBenchMarkConf();
        String stateDataDirPath = benchMarkConfig.getString(StateBenchmarkOptions.STATE_DATA_DIR);
        benchmark =
                new RescalingBenchmarkBuilder<byte[]>()
                        .setMaxParallelism(128)
                        .setParallelismBefore(rescaleType.getParallelismBefore())
                        .setParallelismAfter(rescaleType.getParallelismAfter())
                        .setCheckpointStorageAccess(
                                new FileSystemCheckpointStorage(new URI("file://" + stateDataDirPath), 0)
                                        .createCheckpointStorage(new JobID()))
                        .setStateBackend(stateBackend)
                        .setStreamRecordGenerator(new ByteArrayRecordGenerator(numberOfKeys, keyLen))
                        .setStateProcessFunctionSupplier(TestKeyedFunction::new)
                        .build();
        benchmark.setUp();
    }