public void endInput()

in src/main/java/org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java [278:294]

• 14 lines of code
• 7 McCabe index (conditional complexity)

        public void endInput(int inputId) {
            if (inputId == 1) {
                input1Finished = true;
            }

            if (inputId == 2) {
                input2Finished = true;
            }

            if (inputId == 3) {
                input3Finished = true;
            }

            if (input1Finished && input2Finished && input3Finished) {
                output.collect(new StreamRecord<>(asserter.getSeenRecords()));
            }
        }