public JobErrorRanges fetchErrorRanges()

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

12 lines of code
2 McCabe index (conditional complexity)


    public JobErrorRanges fetchErrorRanges(UUID jobId) {
        JobSummary summary = fetchJobSummary(jobId);
        List<ResultSetFuture> futures = Lists.newArrayListWithCapacity(summary.buckets);

        for (int i = 0; i < summary.buckets; i++)
            futures.add(session.executeAsync(jobErrorRangesStatement.bind(jobId, i)));

        Map<String, List<Range>> errorRangesByTable = Maps.newHashMapWithExpectedSize(summary.keyspaceTables.size());
        processFutures(futures, row -> errorRangesByTable.merge(row.getString("qualified_table_name"),
                                                                Lists.newArrayList(new Range(row.getString("start_token"),
                                                                                             row.getString("end_token"))),
                                                                (l1, l2) -> { l1.addAll(l2); return l1;}));
        return new JobErrorRanges(jobId, errorRangesByTable);
    }