org.apache.drill.exec.store.mapr.db.json

Class MaprDBJsonRecordReader

java.lang.Object

org.apache.drill.exec.store.AbstractRecordReader

org.apache.drill.exec.store.mapr.db.json.MaprDBJsonRecordReader

All Implemented Interfaces:

AutoCloseable, RecordReader

Direct Known Subclasses:

RestrictedJsonRecordReader

public class MaprDBJsonRecordReader
extends AbstractRecordReader

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	MaprDBJsonRecordReader.SchemaState

Field Summary

Fields

Modifier and Type	Field and Description
protected org.ojai.store.QueryCondition	condition
protected org.apache.drill.exec.store.mapr.db.json.DocumentReaderVectorWriter	documentWriter
protected MapRDBFormatPlugin	formatPlugin
protected static org.ojai.FieldPath[]	ID_ONLY_PROJECTION
protected org.ojai.Document	lastDocument
protected com.mapr.db.ojai.DBDocumentReaderBase	lastDocumentReader
protected int	maxRecordsToRead
protected MapRDBSubScanSpec	subScanSpec
protected com.mapr.db.Table	table
protected OjaiValueWriter	valueWriter
protected VectorContainerWriter	vectorWriter
protected OutputMutator	vectorWriterMutator

Fields inherited from class org.apache.drill.exec.store.AbstractRecordReader

DEFAULT_TEXT_COLS_TO_READ

Fields inherited from interface org.apache.drill.exec.store.RecordReader

ALLOCATOR_INITIAL_RESERVATION, ALLOCATOR_MAX_RESERVATION

Constructor Summary

Constructors

Modifier	Constructor and Description
	MaprDBJsonRecordReader(MapRDBSubScanSpec subScanSpec, MapRDBFormatPlugin formatPlugin, List<SchemaPath> projectedColumns, FragmentContext context, int maxRecords, TupleMetadata schema)
protected	MaprDBJsonRecordReader(MapRDBSubScanSpec subScanSpec, MapRDBFormatPlugin formatPlugin, List<SchemaPath> projectedColumns, FragmentContext context, TupleMetadata schema)

Method Summary

Modifier and Type	Method and Description
void	close()
protected boolean	getIdOnly()
protected boolean	getIgnoreSchemaChange()
protected org.ojai.FieldPath[]	getScannedFields()
protected com.mapr.db.Table	getTable()
static boolean	includesIdField(Collection<org.ojai.FieldPath> projected)
int	next() Increments this record reader forward, writing via the provided output mutator into the output batch.
protected org.ojai.Document	nextDocument()
protected com.mapr.db.ojai.DBDocumentReaderBase	nextDocumentReader()
void	setup(OperatorContext context, OutputMutator output) Configure the RecordReader with the provided schema and the record batch that should be written to.
String	toString()
protected Collection<SchemaPath>	transformColumns(Collection<SchemaPath> columns)

Methods inherited from class org.apache.drill.exec.store.AbstractRecordReader

allocate, getColumns, getDefaultColumnsToRead, hasNext, isSkipQuery, isStarQuery, setColumns

Methods inherited from class java.lang.Object

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

Field Detail

ID_ONLY_PROJECTION

protected static final org.ojai.FieldPath[] ID_ONLY_PROJECTION

table

protected com.mapr.db.Table table

condition

protected org.ojai.store.QueryCondition condition

vectorWriter

protected VectorContainerWriter vectorWriter

vectorWriterMutator

protected OutputMutator vectorWriterMutator

subScanSpec

protected final MapRDBSubScanSpec subScanSpec

formatPlugin

protected final MapRDBFormatPlugin formatPlugin

valueWriter

protected OjaiValueWriter valueWriter

documentWriter

protected org.apache.drill.exec.store.mapr.db.json.DocumentReaderVectorWriter documentWriter

maxRecordsToRead

protected int maxRecordsToRead

lastDocumentReader

protected com.mapr.db.ojai.DBDocumentReaderBase lastDocumentReader

lastDocument

protected org.ojai.Document lastDocument

Constructor Detail

MaprDBJsonRecordReader

public MaprDBJsonRecordReader(MapRDBSubScanSpec subScanSpec,
                              MapRDBFormatPlugin formatPlugin,
                              List<SchemaPath> projectedColumns,
                              FragmentContext context,
                              int maxRecords,
                              TupleMetadata schema)

MaprDBJsonRecordReader

protected MaprDBJsonRecordReader(MapRDBSubScanSpec subScanSpec,
                                 MapRDBFormatPlugin formatPlugin,
                                 List<SchemaPath> projectedColumns,
                                 FragmentContext context,
                                 TupleMetadata schema)

Method Detail

transformColumns

protected Collection<SchemaPath> transformColumns(Collection<SchemaPath> columns)

Overrides:

transformColumns in class AbstractRecordReader

getScannedFields

protected org.ojai.FieldPath[] getScannedFields()

getIdOnly

protected boolean getIdOnly()

getTable

protected com.mapr.db.Table getTable()

getIgnoreSchemaChange

protected boolean getIgnoreSchemaChange()

setup

public void setup(OperatorContext context,
                  OutputMutator output)
           throws ExecutionSetupException

Description copied from interface: RecordReader

Configure the RecordReader with the provided schema and the record batch that should be written to.

Parameters:

context - operator context for the reader

output - The place where output for a particular scan should be written. The record reader is responsible for mutating the set of schema values for that particular record.

Throws:

ExecutionSetupException

next

public int next()

Description copied from interface: RecordReader

Increments this record reader forward, writing via the provided output mutator into the output batch.

Returns:

The number of additional records added to the output.

nextDocumentReader

protected com.mapr.db.ojai.DBDocumentReaderBase nextDocumentReader()

nextDocument

protected org.ojai.Document nextDocument()

includesIdField

public static boolean includesIdField(Collection<org.ojai.FieldPath> projected)

close

public void close()

toString

public String toString()

Overrides:

toString in class AbstractRecordReader