Class ParquetScanBatchCreator
java.lang.Object
org.apache.drill.exec.store.parquet.AbstractParquetScanBatchCreator
org.apache.drill.exec.store.parquet.ParquetScanBatchCreator
- All Implemented Interfaces:
BatchCreator<ParquetRowGroupScan>
public class ParquetScanBatchCreator
extends AbstractParquetScanBatchCreator
implements BatchCreator<ParquetRowGroupScan>
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic class
Creates file system only if it was not created before, otherwise returns already created instance.Nested classes/interfaces inherited from class org.apache.drill.exec.store.parquet.AbstractParquetScanBatchCreator
AbstractParquetScanBatchCreator.AbstractDrillFileSystemManager
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptiongetBatch
(ExecutorFragmentContext context, ParquetRowGroupScan rowGroupScan, List<RecordBatch> children) getDrillFileSystemCreator
(OperatorContext operatorContext, OptionManager optionManager) Methods inherited from class org.apache.drill.exec.store.parquet.AbstractParquetScanBatchCreator
getBatch, getImplicitValues
-
Constructor Details
-
ParquetScanBatchCreator
public ParquetScanBatchCreator()
-
-
Method Details
-
getBatch
public ScanBatch getBatch(ExecutorFragmentContext context, ParquetRowGroupScan rowGroupScan, List<RecordBatch> children) throws ExecutionSetupException - Specified by:
getBatch
in interfaceBatchCreator<ParquetRowGroupScan>
- Throws:
ExecutionSetupException
-
getDrillFileSystemCreator
protected AbstractParquetScanBatchCreator.AbstractDrillFileSystemManager getDrillFileSystemCreator(OperatorContext operatorContext, OptionManager optionManager) - Specified by:
getDrillFileSystemCreator
in classAbstractParquetScanBatchCreator
-