private Iterator randomlyExecute()

in paimon-python-java-bridge/src/main/java/org/apache/paimon/python/ParallelBytesReader.java [110:117]

• 8 lines of code
• 2 McCabe index (conditional complexity)

    private <U, T> Iterator<T> randomlyExecute(
            ExecutorService executor, Function<U, Iterator<T>> processor, Collection<U> input) {
        List<Future<Iterator<T>>> futures = new ArrayList<>(input.size());
        for (U u : input) {
            futures.add(executor.submit(() -> processor.apply(u)));
        }
        return futuresToIterIter(futures);
    }