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