in flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/utils/KuduSplitGenerator.java [91:102]
private List<KuduSourceSplit> serializeTokens(List<KuduScanToken> tokens) {
try {
List<KuduSourceSplit> splits = new ArrayList<>();
for (KuduScanToken token : tokens) {
splits.add(new KuduSourceSplit(token.serialize()));
}
return splits;
} catch (Exception e) {
throw new RuntimeException(
"Error during source split serialization: " + e.getMessage(), e);
}
}