docs: @Override
  	public void collect(IT record) {
  		numRecordsIn.inc();
  		try {
  			if (base == null) {
  				base = serializer.copy(record);
  			} else {
  				base = objectReuseEnabled ? reducer.reduce(base, record) : serializer.copy(reducer.reduce(base, record));
  			}
  		} catch (Exception e) {
  			throw new ExceptionInChainedStubException(taskName, e);
  		}
  	}