public ProcessResult reduce()

in schedulerx-demo/schedulerx-example-springboot/src/main/java/com/aliyun/schedulerx/example/processor/TradeOrderJob.java [51:67]

• 15 lines of code
• 4 McCabe index (conditional complexity)

    public ProcessResult reduce(JobContext context) throws Exception {
        Map<Long, String> allTaskResults = context.getTaskResults();
        Map<Long, TaskStatus> allTaskStatuses = context.getTaskStatuses();
        long sum = 0;
        for (Entry<Long, String> entry : allTaskResults.entrySet()) {
            // 过滤根任务
            if (entry.getKey() == 0) {
                continue;
            }
            if (allTaskStatuses.get(entry.getKey()).equals(TaskStatus.SUCCESS)) {
                sum += Integer.valueOf(entry.getValue());
            }
        }
        
        LOGGER.info("reduce: count=" + sum);
        return new ProcessResult(true, String.valueOf(sum));
    }