class Distinct implements CombinerAggregator<Set<Integer>> {

  @Override
  public Set<Integer> combine(Set<Integer> val1, Set<Integer> val2) {
    Set<Integer> union = new HashSet<Integer>();
    union.addAll(val1);
    union.addAll(val2);
    return union;
  }

}