public Collection fetchJobsStartedBetween()

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

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

    public Collection<JobSummary> fetchJobsStartedBetween(DateTime start, DateTime end) {
        int days = Days.daysBetween(start, end).getDays();
        List<ResultSetFuture> idFutures = Lists.newArrayListWithCapacity(days * 24);
        for (int i = 0; i <= days; i++) {
            DateTime date = start.plusDays(i);
            LocalDate ld = LocalDate.fromYearMonthDay(date.getYear(), date.getMonthOfYear(), date.getDayOfMonth());
            for (int j = 0; j <= 23; j++) {
                idFutures.add(session.executeAsync(jobsStartDateStatement.bind(ld, j)));
            }
        }

        List<ResultSetFuture> jobFutures = Lists.newArrayList();
        processFutures(idFutures,
                       row -> session.executeAsync(jobSummaryStatement.bind(row.getUUID("job_id"))),
                       jobFutures::add);

        SortedSet<JobSummary> jobs = Sets.newTreeSet(JobSummary.COMPARATOR.reversed());
        processFutures(jobFutures, JobSummary::fromRow, jobs::add);
        return jobs;
    }