protected CompletableFuture innerGetNextBatch()

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()));
    }