class IntegerMaxKudaf extends KsqlAggregateFunction<Integer, Integer> {

  @Override
  public Integer aggregate(Integer currentVal, Integer currentAggVal) {
    if (currentVal == null) {
      return currentAggVal;
    }
    return Math.max(currentVal, currentAggVal);
  }

  public  IntegerMaxKudaf(int argIndexInValue);

}