public AggregateParams create(
      final LogicalSchema schema,
      final List<ColumnName> nonAggregateColumns,
      final FunctionRegistry functionRegistry,
      final List<FunctionCall> functionList,
      final boolean windowedAggregation,
      final KsqlConfig config
  ) {
    return create(
        schema,
        nonAggregateColumns,
        functionRegistry,
        functionList,
        false,
        windowedAggregation,
        config
    );
  }
@SuppressWarnings("unchecked")
  @Test
  public void shouldCreateAggregatorWithCorrectParams() {
    verify(udafFactory).create(2, ImmutableList.of(agg0, agg1));
  }