aggregateStage method

dynamic aggregateStage(
  1. List<RetrieveReport> reports,
  2. RADAggregate aggregate
)

Implementation

dynamic aggregateStage(List<RetrieveReport> reports, RADAggregate aggregate) {
  List<num> values = [];
  for (int i = 0; i < reports.length; i++) {
    RetrieveReport report = reports[i];

    if (report.trace.last[1] == null) {
      report.trace.removeLast();
    }

    values.add(report.trace.last[1].value);
  }
  Stats stats = Stats.fromData(values);

  return Reducer.op(aggregate.reducer, stats);
}