public void processElement()

in src/main/java/org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java [202:210]

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

        public void processElement(Integer element) {
            this.seenRecords++;
            if (!Objects.equals(element, currentKey)) {
                if (!seenKeys.add(element)) {
                    Assert.fail("Received an out of order key: " + element);
                }
                currentKey = element;
            }
        }