class BaseAggregateFunction implements KsqlAggregateFunction<I, A, O> {

  @Override
  public SqlType returnType() {
    return outputSchema;
  }

  public  BaseAggregateFunction(
      final String functionName,
      final int argIndexInValue,
      final Supplier<A> initialValueSupplier,
      final SqlType aggregateType,
      final SqlType outputType,
      final List<ParameterInfo> parameters,
      final String description
  );

}