protected CompletableFuture innerGetNextBatch()

in src/main/java/org/apache/paimon/trino/TrinoSplitSource.java [43:54]

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

    protected CompletableFuture<ConnectorSplitBatch> innerGetNextBatch(int maxSize) {
        List<ConnectorSplit> batch = new ArrayList<>();
        for (int i = 0; i < maxSize; i++) {
            TrinoSplit split = splits.poll();
            if (split == null || (limit.isPresent() && count >= limit.getAsLong())) {
                break;
            }
            count += split.decodeSplit().rowCount();
            batch.add(split);
        }
        return CompletableFuture.completedFuture(new ConnectorSplitBatch(batch, isFinished()));
    }