public void endInput()

in src/main/java/org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java [249:261]

• 11 lines of code
• 5 McCabe index (conditional complexity)

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

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

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