public List generateFullScanSplits()

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

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

    public List<KuduSourceSplit> generateFullScanSplits(long snapshotTimestamp) {
        if (snapshotTimestamp <= 0) {
            throw new IllegalArgumentException(
                    "Snapshot timestamp must be greater than 0, but was: " + snapshotTimestamp);
        }
        try {
            List<KuduScanToken> tokens =
                    obtainScanTokenBuilder(tableInfo.getName())
                            .snapshotTimestampRaw(snapshotTimestamp)
                            .readMode(AsyncKuduScanner.ReadMode.READ_AT_SNAPSHOT)
                            .build();
            return serializeTokens(tokens);
        } catch (Exception e) {
            throw new RuntimeException("Error during full snapshot scan: " + e.getMessage(), e);
        }
    }