Class RecordReader<T>

  • Type Parameters:
    T - the type of the materialized record
    Direct Known Subclasses:
    BaseRecordReader

    public abstract class RecordReader<T>
    extends Object
    used to read reassembled records
    • Constructor Detail

      • RecordReader

        public RecordReader()
    • Method Detail

      • read

        public abstract T read()
        Reads one record and returns it.
        Returns:
        the materialized record
      • shouldSkipCurrentRecord

        public boolean shouldSkipCurrentRecord()
        Returns whether the current record should be skipped (dropped) Will be called *after* read()
        Returns:
        true if the current record should be skipped