protected CompletableFuture innerGetNextBatch()

in paimon-trino-common/src/main/java/org/apache/paimon/trino/TrinoSplitSourceBase.java [39:49]

• 11 lines of code
• 3 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) {
                break;
            }
            batch.add(split);
        }
        return CompletableFuture.completedFuture(new ConnectorSplitBatch(batch, isFinished()));
    }