Package org.apache.drill.exec.store.parquet

Class AbstractParquetScanBatchCreator

java.lang.Object

org.apache.drill.exec.store.parquet.AbstractParquetScanBatchCreator

Direct Known Subclasses:

DeltaScanBatchCreator, HiveDrillNativeParquetScanBatchCreator, ParquetScanBatchCreator

public abstract class AbstractParquetScanBatchCreator
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	AbstractParquetScanBatchCreator.AbstractDrillFileSystemManager	Helper class responsible for creating and managing DrillFileSystem.

Constructor Summary

Constructors

Constructor	Description
AbstractParquetScanBatchCreator()

Method Summary

Modifier and Type	Method	Description
protected ScanBatch	getBatch(ExecutorFragmentContext context, AbstractParquetRowGroupScan rowGroupScan, OperatorContext oContext)
protected abstract AbstractParquetScanBatchCreator.AbstractDrillFileSystemManager	getDrillFileSystemCreator(OperatorContext operatorContext, OptionManager optionManager)
protected Map<String,String>	getImplicitValues(AbstractParquetRowGroupScan rowGroupScan, ColumnExplorer columnExplorer, RowGroupReadEntry rowGroup, DrillFileSystem fs)

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractParquetScanBatchCreator

public AbstractParquetScanBatchCreator()

Method Details

getBatch

protected ScanBatch getBatch(ExecutorFragmentContext context,
 AbstractParquetRowGroupScan rowGroupScan,
 OperatorContext oContext)
                      throws ExecutionSetupException

Throws:

ExecutionSetupException

getImplicitValues

protected Map<String,String> getImplicitValues(AbstractParquetRowGroupScan rowGroupScan,
 ColumnExplorer columnExplorer,
 RowGroupReadEntry rowGroup,
 DrillFileSystem fs)

getDrillFileSystemCreator

protected abstract AbstractParquetScanBatchCreator.AbstractDrillFileSystemManager getDrillFileSystemCreator(OperatorContext operatorContext,
 OptionManager optionManager)