public void setUp()

in src/main/java/org/apache/flink/state/benchmark/MapStateBenchmark.java [60:77]

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

    public void setUp() throws Exception {
        keyedStateBackend = createKeyedStateBackend();
        mapState =
                getMapState(
                        keyedStateBackend,
                        new MapStateDescriptor<>("mapState", Long.class, Double.class));
        dummyMaps = new HashMap<>(mapKeyCount);
        for (int i = 0; i < mapKeyCount; ++i) {
            dummyMaps.put(mapKeys.get(i), random.nextDouble());
        }
        for (int i = 0; i < setupKeyCount; ++i) {
            keyedStateBackend.setCurrentKey((long) i);
            for (int j = 0; j < mapKeyCount; j++) {
                mapState.put(mapKeys.get(j), random.nextDouble());
            }
        }
        keyIndex = new AtomicInteger();
    }