Instantiates a new deep record reader object associated to the provided partition.

@param dp a spark deep partition
@return the deep record reader associated to the provided partition.
17028
private DeepRecordReader initRecordReader(final DeepPartition dp,
                                               CassandraDeepJobConfig<T> config) {

        DeepRecordReader recordReader = new DeepRecordReader(config, dp.splitWrapper());

        return recordReader;

    }
27490
public <T> T read(final Reader reader, final DataTypeDescriptor<T> descriptor)
			throws Exception {
		if (reader == null) throw new NullPointerException("reader");
		if (descriptor == null) throw new NullPointerException("descriptor");

		JsonParser parser = factory.createParser(reader);
		return read(parser, descriptor);
	}
1063584
@Override
  @SuppressWarnings("unchecked")
  public D readRecord(@Deprecated D reuse) throws DataRecordException, IOException {
    try {
      if (this.recordReader.nextKeyValue()) {
        return this.readKeys ? (D) this.recordReader.getCurrentKey() : (D) this.recordReader.getCurrentValue();
      }
    } catch (InterruptedException ie) {
      throw new IOException(ie);
    }

    return null;
  }
251701
public FSEditLogOp readOp() throws IOException {
    FSEditLogOp ret;
    if (cachedOp != null) {
      ret = cachedOp;
      cachedOp = null;
      return ret;
    }
    return nextOp();
  }
16284
protected Iterator<WorkUnit> getWorkUnitIterator(Iterator<Dataset> datasetIterator, String previousDatasetUrnWatermark,
      @Nullable String previousPartitionUrnWatermark, int maximumWorkUnits) throws IOException {
    return new DeepIterator(datasetIterator, previousDatasetUrnWatermark, previousPartitionUrnWatermark,
            maximumWorkUnits);
  }
304995
public static Map<String, IDLProxyObject> create(Reader reader, boolean debug, File path) throws IOException {
        return create(reader, debug, path, true);
    }
491929
public <DPO> MultipleDataProviderContext<DPO> read(Collection<DataProvider<DPO>> dataProviders) {
        List<DataProvider<DPO>> addedDataProviders = new ArrayList<DataProvider<DPO>>();
        if (dataProviders != null) {
            addedDataProviders.addAll(dataProviders);
        }

        // Change context
        return new MultipleDataProviderContext<DPO>(addedTriggers, addedDataProviders);
    }
1194795
@Override
    public void prepareToRead(@SuppressWarnings("rawtypes") RecordReader newReader, PigSplit pigSplit) {
        // Note that for this Loader, we don't care about the PigSplit.
        if (newReader instanceof ApacheHttpdLogfileRecordReader) {
            this.reader = (ApacheHttpdLogfileRecordReader) newReader;
        } else {
            throw new IncorrectRecordReaderException();
        }
    }
131561
@Override
    public RecordReader<LongWritable, WARCWritable> getRecordReader(InputSplit split, JobConf job, Reporter reporter)
            throws IOException {
        reporter.setStatus(split.toString());
        return new WARCReader(job, (FileSplit) split);
    }
803884
public MultipleDataProviderContext<DPO> read(Collection<DataProvider<DPO>> dataProviders) {
        if (dataProviders != null) {
            addedDataProviders.addAll(dataProviders);
        }

        // Stay in the same context and re-use the same instance because no type has changed
        return this;
    }
337933
public static IDLProxyObject createSingle(Reader reader, boolean debug) throws IOException {
        return createSingle(reader, debug, null);
    }
1274074
public <T> JavaRDD<T> createJavaRDD(
            ExtractorConfig<T> config) {
        return new DeepJavaRDD<>((DeepRDD<T, ExtractorConfig<T>>) createRDD(config));
    }
583500
public static Object deepBox(Object src) {
        Class<?> resultType = arrayBoxingType(src.getClass());
        return deepBox(resultType, src);
    }
1099416
public static final Object deepCopy(Object source, final KunderaMetadata kunderaMetadata)
    {
        Map<Object, Object> copiedObjectMap = new HashMap<Object, Object>();

        Object target = deepCopyUsingMetadata(source, copiedObjectMap, kunderaMetadata);

        copiedObjectMap.clear();
        copiedObjectMap = null;

        return target;
    }
807042
@Override public RecordReader<LongWritable,SAMRecordWritable>
		createRecordReader(InputSplit split, TaskAttemptContext ctx)
			throws InterruptedException, IOException
	{
		final RecordReader<LongWritable,SAMRecordWritable> rr =
			new SAMRecordReader();
		rr.initialize(split, ctx);
		return rr;
	}
318608
public static <T> T deepBoxAs(Object src, Class<T> type) {
        return (T) deepBox(type, src);
    }
1246257
private boolean isRecordAlreadyRead(
      final PartitionIdType recordPartition,
      final SequenceOffsetType recordSequenceNumber
  )
  {
    final SequenceOffsetType lastReadOffset = lastReadOffsets.get(recordPartition);

    if (lastReadOffset == null) {
      return false;
    } else {
      return createSequenceNumber(recordSequenceNumber).compareTo(createSequenceNumber(lastReadOffset)) <= 0;
    }
  }