in paimon-prestosql-common/src/main/java/org/apache/paimon/prestosql/PrestoSqlSplitSourceBase.java [39:49]
protected CompletableFuture<ConnectorSplitBatch> innerGetNextBatch(int maxSize) {
List<ConnectorSplit> batch = new ArrayList<>();
for (int i = 0; i < maxSize; i++) {
PrestoSqlSplit split = splits.poll();
if (split == null) {
break;
}
batch.add(split);
}
return CompletableFuture.completedFuture(new ConnectorSplitBatch(batch, isFinished()));
}