public CompletableFuture getNextBatch()

in paimon-presto-common/src/main/java/org/apache/paimon/presto/PrestoSplitSource.java [41:52]

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

    public CompletableFuture<ConnectorSplitBatch> getNextBatch(
            ConnectorPartitionHandle partitionHandle, int maxSize) {
        List<ConnectorSplit> batch = new ArrayList<>();
        for (int i = 0; i < maxSize; i++) {
            PrestoSplit split = splits.poll();
            if (split == null) {
                break;
            }
            batch.add(split);
        }
        return CompletableFuture.completedFuture(new ConnectorSplitBatch(batch, isFinished()));
    }