public JobMismatches fetchMismatches()

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

12 lines of code
2 McCabe index (conditional complexity)


    public JobMismatches fetchMismatches(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(jobMismatchesStatement.bind(jobId, i)));

        Map<String, List<Mismatch>> mismatchesByTable = Maps.newHashMapWithExpectedSize(summary.keyspaceTables.size());
        processFutures(futures, row -> mismatchesByTable.merge(row.getString("qualified_table_name"),
                                                               Lists.newArrayList(new Mismatch(row.getString("mismatching_token"),
                                                                                               row.getString("mismatch_type"))),
                                                               (l1, l2) -> { l1.addAll(l2); return l1;}));
        return new JobMismatches(jobId, mismatchesByTable);
    }