public void mapEntries()

in src/main/java/org/apache/flink/state/benchmark/MapStateBenchmark.java [129:138]

• 10 lines of code
• 3 McCabe index (conditional complexity)

    public void mapEntries(KeyValue keyValue, Blackhole bh) throws Exception {
        keyedStateBackend.setCurrentKey(keyValue.setUpKey);
        Iterable<Map.Entry<Long, Double>> iterable = mapState.entries();
        if (iterable != null) {
            for (Map.Entry<Long, Double> entry : mapState.entries()) {
                bh.consume(entry.getKey());
                bh.consume(entry.getValue());
            }
        }
    }