Package org.apache.drill.exec.store.hive.readers.inspectors

Class AbstractRecordsInspector

java.lang.Object
org.apache.drill.exec.store.hive.readers.inspectors.AbstractRecordsInspector
Direct Known Subclasses:
SkipFooterRecordsInspector
public abstract class AbstractRecordsInspector extends Object
Parent class for records inspectors which responsible for counting of processed records and managing free and used value holders.

  • Constructor Details

    • AbstractRecordsInspector

      public AbstractRecordsInspector()

  • Method Details

    • isBatchFull

      public boolean isBatchFull()
      Checks if current number of processed records does not exceed max batch size.
      Returns:
      true if reached max number of records in batch

    • getProcessedRecordCount

      public int getProcessedRecordCount()
      Returns:
      number of processed records

    • incrementProcessedRecordCount

      public void incrementProcessedRecordCount()
      Increments current number of processed records.

    • reset

      public void reset()
      When batch of data was sent, number of processed records should be reset.

    • getValueHolder

      public abstract Object getValueHolder()
      Returns value holder where next value will be written.
      Returns:
      value holder

    • getNextValue

      public abstract Object getNextValue()
      Returns:
      value holder with written value