Package org.apache.drill.exec.store.delta.read

Class DeltaScanBatchCreator

java.lang.Object

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

org.apache.drill.exec.store.delta.read.DeltaScanBatchCreator

All Implemented Interfaces:

BatchCreator<DeltaRowGroupScan>

public class DeltaScanBatchCreator
extends AbstractParquetScanBatchCreator
implements BatchCreator<DeltaRowGroupScan>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.exec.store.parquet.AbstractParquetScanBatchCreator

AbstractParquetScanBatchCreator.AbstractDrillFileSystemManager

Constructor Summary

Constructors

Constructor	Description
DeltaScanBatchCreator()

Method Summary

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

Methods inherited from class org.apache.drill.exec.store.parquet.AbstractParquetScanBatchCreator

getBatch

Methods inherited from class java.lang.Object

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

Constructor Details

DeltaScanBatchCreator

public DeltaScanBatchCreator()

Method Details

getBatch

public CloseableRecordBatch getBatch(ExecutorFragmentContext context,
 DeltaRowGroupScan rowGroupScan,
 List<RecordBatch> children)
                              throws ExecutionSetupException

Specified by:

getBatch in interface BatchCreator<DeltaRowGroupScan>

Throws:

ExecutionSetupException

getDrillFileSystemCreator

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

Specified by:

getDrillFileSystemCreator in class AbstractParquetScanBatchCreator

getImplicitValues

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

Overrides:

getImplicitValues in class AbstractParquetScanBatchCreator