code: @Private
    @Override
    public void aggregationCompleted(final List<Integer> taskletIds, final TOutput result) {
      try {
        completedTasklets(result, taskletIds);
      } catch (final InterruptedException e) {
        throw new RuntimeException(e);
      }
    }
docs: Aggregation has completed for a list of Tasklets, with an aggregated result.