class IntegerSumKudaf extends KsqlAggregateFunction<Integer, Integer> {

  @Override
  public Merger<String, Integer> getMerger() {
    return (aggKey, aggOne, aggTwo) -> aggOne + aggTwo;
  }

    IntegerSumKudaf(int argIndexInValue);

}