public List generateIncrementalSplits()

in flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/utils/KuduSplitGenerator.java [65:89]

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

    public List<KuduSourceSplit> generateIncrementalSplits(long startHT, long endHT) {
        if (startHT <= 0 || endHT <= 0) {
            throw new IllegalArgumentException(
                    "Start and end timestamps must be greater than 0. Given startHT: "
                            + startHT
                            + ", endHT: "
                            + endHT);
        }

        if (startHT >= endHT) {
            throw new IllegalArgumentException(
                    "Start timestamp must be less than end timestamp. Given startHT: "
                            + startHT
                            + ", endHT: "
                            + endHT);
        }

        try {
            List<KuduScanToken> tokens =
                    obtainScanTokenBuilder(tableInfo.getName()).diffScan(startHT, endHT).build();
            return serializeTokens(tokens);
        } catch (Exception e) {
            throw new RuntimeException("Error during incremental diff scan: " + e.getMessage(), e);
        }
    }