class IntegerMaxKudaf extends KsqlAggregateFunction<Integer, Integer> {

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

  public  IntegerMaxKudaf(int argIndexInValue);

}