public JobErrorSummary fetchErrorSummary()

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

• 16 lines of code
• 3 McCabe index (conditional complexity)

    public JobErrorSummary fetchErrorSummary(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(jobErrorSummaryStatement.bind(jobId, i)));

        Map<String, Long> errorCountByTable = Maps.newHashMapWithExpectedSize(summary.keyspaceTables.size());
        processFutures(futures, row -> {
            String table = row.getString("qualified_table_name");
            if (null != table) {
                errorCountByTable.merge(row.getString("qualified_table_name"),
                                        row.getLong("error_count"),
                                        Long::sum);
            }
        });
        return new JobErrorSummary(jobId, errorCountByTable);
    }