public void start()

in flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/enumerator/KuduSourceEnumerator.java [130:137]

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

    public void start() {
        if (boundedness == Boundedness.CONTINUOUS_UNBOUNDED) {
            context.callAsync(
                    this::enumerateNewSplits, this::assignSplits, 0, discoveryInterval.toMillis());
        } else if (boundedness == Boundedness.BOUNDED) {
            context.callAsync(this::enumerateNewSplits, this::assignSplits);
        }
    }