code: private Iterator<D> getIterator() throws DataRecordException, IOException {
      if (Boolean.valueOf(this.workUnitState.getProp(ConfigurationKeys.SOURCE_QUERYBASED_IS_SPECIFIC_API_ACTIVE))) {
        return this.getRecordSetFromSourceApi(this.schema, this.entity, this.workUnit, this.predicateList);
      }
      return this.getRecordSet(this.schema, this.entity, this.workUnit, this.predicateList);
    }
docs: Get iterator from protocol specific api if is.specific.api.active is false
  Get iterator from source specific api if is.specific.api.active is true
  @return iterator