@Test
public void testInit() throws Exception {

  TridentTuple tuple = mock(TridentTuple.class);
  when(tuple.getInteger(1)).thenReturn(1);
  Set<Integer> init = distinct.init(tuple);
  assertThat(init)
          .isNotNull()
          .hasSize(1)
          .contains(1);
}