public void run()

in src/main/java/org/apache/flink/benchmark/functions/BaseSourceWithKeyRange.java [40:54]

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

    public void run(SourceContext<T> out) {
        init();

        int keyId = 0;
        while (--remainingEvents >= 0) {
            T element = getElement(keyId);
            synchronized (out.getCheckpointLock()) {
                out.collect(element);
            }
            ++keyId;
            if (keyId >= numKeys) {
                keyId = 0;
            }
        }
    }