One implements CombinerAggregator<Integer> { @Override public Integer combine(Integer val1, Integer val2) { return 1; }  @Override Integer init(TridentTuple tuple); @Override Integer combine(Integer val1, Integer val2); @Override Integer zero();  }
@Test public void testCombine() throws Exception { assertThat(one.combine(ANY_INT_ONE, ANY_INT_TWO)).isEqualTo(1); }