Class AbstractPojoRecordReader<T>

All Implemented Interfaces:
AutoCloseable, Iterable<T>, RecordReader
Direct Known Subclasses:
DynamicPojoRecordReader, PojoRecordReader

public abstract class AbstractPojoRecordReader<T> extends AbstractRecordReader implements Iterable<T>
Parent class for all pojo readers. Pojo readers can be based on java class (field list is predefined) or dynamic. Contains general logic for initiating writers and reading values from each row fields.
  • Field Details

  • Constructor Details

    • AbstractPojoRecordReader

      protected AbstractPojoRecordReader(List<T> records)
    • AbstractPojoRecordReader

      protected AbstractPojoRecordReader(List<T> records, int recordsPerBatch)
  • Method Details