docs: @Override
  	public BaseRow addInput(@Nullable BaseRow previousAcc, BaseRow input) throws Exception {
  		BaseRow currentAcc;
  		if (previousAcc == null) {
  			currentAcc = localAgg.createAccumulators();
  		} else {
  			currentAcc = previousAcc;
  		}
  
  		localAgg.setAccumulators(currentAcc);
  		localAgg.merge(input);
  		return localAgg.getAccumulators();
  	}