private List enumerateNewSplits()

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

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

    private List<KuduSourceSplit> enumerateNewSplits() {
        if (!shouldEnumerateNewSplits()) {
            return null;
        }
        List<KuduSourceSplit> newSplits;

        if (isFirstSplitGeneration()) {
            lastEndTimestamp = KuduSourceUtils.getCurrentHybridTime();
            newSplits = splitGenerator.generateFullScanSplits(lastEndTimestamp);
        } else {
            long startHT = lastEndTimestamp;
            long endHT = KuduSourceUtils.getCurrentHybridTime();
            newSplits = splitGenerator.generateIncrementalSplits(startHT, endHT);
            lastEndTimestamp = endHT;
        }

        return newSplits;
    }