public Collection fetchJobResults()

in api-server/src/main/java/org/apache/cassandra/diff/api/services/DBService.java [190:199]

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

    public Collection<JobResult> fetchJobResults(UUID jobId) {
        JobSummary summary = fetchJobSummary(jobId);
        List<ResultSetFuture> futures = Lists.newArrayListWithCapacity(summary.keyspaceTables.size());
        for (String table : summary.keyspaceTables)
            futures.add(session.executeAsync(jobResultStatement.bind(jobId, table)));

        SortedSet<JobResult> results = Sets.newTreeSet();
        processFutures(futures, JobResult::fromRow, results::add);
        return results;
    }