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

Class SkipFooterRecordsInspector

java.lang.Object

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

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

public class SkipFooterRecordsInspector
extends AbstractRecordsInspector

To implement skip footer logic this records inspector will buffer N number of incoming read records in queue and make sure they are skipped when input is fully processed. FIFO method of queuing is used for these purposes.

Constructor Summary

Constructors

Constructor	Description
SkipFooterRecordsInspector(org.apache.hadoop.mapred.RecordReader<Object,Object> reader, int footerCount)

Method Summary

Modifier and Type	Method	Description
Object	getNextValue()	Buffers current value holder with written value and returns last buffered value if number of buffered values exceeds N records to skip.
Object	getValueHolder()	Returns next available value holder where value should be written from the cached value holders.

Methods inherited from class org.apache.drill.exec.store.hive.readers.inspectors.AbstractRecordsInspector

getProcessedRecordCount, incrementProcessedRecordCount, isBatchFull, reset

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SkipFooterRecordsInspector

public SkipFooterRecordsInspector(org.apache.hadoop.mapred.RecordReader<Object,Object> reader,
 int footerCount)

Method Details

getValueHolder

public Object getValueHolder()

Returns next available value holder where value should be written from the cached value holders. Current available holder is determined by getting mod for actually read records.

Specified by:

getValueHolder in class AbstractRecordsInspector

Returns:

value holder

getNextValue

public Object getNextValue()

Buffers current value holder with written value and returns last buffered value if number of buffered values exceeds N records to skip.

Specified by:

getNextValue in class AbstractRecordsInspector

Returns:

next available value holder with written value, null otherwise