private void assignSplits()

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

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

    private void assignSplits(List<KuduSourceSplit> splits, Throwable error) {
        if (error != null) {
            throw new FlinkRuntimeException(
                    "Failed to enumerate Kudu splits, shutting down job.", error);
        }

        if (splits != null) {
            unassigned.addAll(splits);
        }
        assignSplitsToReaders();
    }