Package org.apache.drill.exec.physical.impl.scan.project

Class ReaderSchemaOrchestrator

java.lang.Object

org.apache.drill.exec.physical.impl.scan.project.ReaderSchemaOrchestrator

All Implemented Interfaces:

VectorSource

public class ReaderSchemaOrchestrator
extends Object
implements VectorSource

Orchestrates projection tasks for a single reader within the set that the scan operator manages. Vectors are reused across readers, but via a vector cache. All other state is distinct between readers.

Constructor Summary

Constructors

Constructor	Description
ReaderSchemaOrchestrator(ScanSchemaOrchestrator scanSchemaOrchestrator, long limit)

Method Summary

Modifier and Type	Method	Description
void	close()
void	defineSchema()
void	endBatch()	Build the final output batch by projecting columns from the three input sources to the output batch.
boolean	endBatch(boolean eof)	Build the final output batch by projecting columns from the three input sources to the output batch.
boolean	hasSchema()
ResultSetLoader	makeTableLoader(CustomErrorContext errorContext, TupleMetadata readerSchema, long localLimit)
ResultSetLoader	makeTableLoader(TupleMetadata readerSchema)
void	setBatchSize(int size)
boolean	startBatch()
ValueVector	vector(int index)

Methods inherited from class java.lang.Object

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

Constructor Details

ReaderSchemaOrchestrator

public ReaderSchemaOrchestrator(ScanSchemaOrchestrator scanSchemaOrchestrator,
 long limit)

Method Details

setBatchSize

public void setBatchSize(int size)

makeTableLoader

public ResultSetLoader makeTableLoader(TupleMetadata readerSchema)

makeTableLoader

public ResultSetLoader makeTableLoader(CustomErrorContext errorContext,
 TupleMetadata readerSchema,
 long localLimit)

hasSchema

public boolean hasSchema()

defineSchema

public void defineSchema()

startBatch

public boolean startBatch()

endBatch

public void endBatch()

Build the final output batch by projecting columns from the three input sources to the output batch. First, build the metadata and/or null columns for the table row count. Then, merge the sources.

endBatch

public boolean endBatch(boolean eof)

Build the final output batch by projecting columns from the three input sources to the output batch. First, build the metadata and/or null columns for the table row count. Then, merge the sources.

Parameters:

eof - is end of file

vector

public ValueVector vector(int index)

Specified by:

vector in interface VectorSource

close

public void close()