code: @Override
      public void setConsumer(IDataSetConsumer consumer) {
          logger.debug("setConsumer(consumer) - start");
  
          if (this._columnSensing) {
              _consumer = new BufferedConsumer(consumer);
          } else {
              _consumer = consumer;
          }
      }
docs: IDataSetProducer interface