@UdafFactory(description = "collect distinct values of a Bigint field into a single Array")
  public static <T> Udaf<T, List<T>, List<T>> createCollectSetT() {
    return new Collect<>();
  }
@Test
  public void shouldIgnoreNegativeLimit() {
    final Udaf<Integer, List<Integer>, List<Integer>> udaf = CollectSetUdaf.createCollectSetT();
    ((Configurable) udaf).configure(ImmutableMap.of(CollectSetUdaf.LIMIT_CONFIG, -1));

    List<Integer> runningList = udaf.initialize();
    for (int i = 1; i <= 25; i++) {
      runningList = udaf.aggregate(i, runningList);
    }

    assertThat(runningList, hasSize(25));
  }