org.apache.drill.exec.store.parquet

Class AbstractParquetRowGroupScan

java.lang.Object

org.apache.drill.exec.physical.base.AbstractBase

org.apache.drill.exec.store.parquet.AbstractParquetRowGroupScan

All Implemented Interfaces:

Iterable<PhysicalOperator>, GraphValue<PhysicalOperator>, FragmentLeaf, Leaf, PhysicalOperator, Scan, SubScan

Direct Known Subclasses:

HiveDrillNativeParquetRowGroupScan, ParquetRowGroupScan

public abstract class AbstractParquetRowGroupScan
extends AbstractBase
implements SubScan

Field Summary

Fields

Modifier and Type	Field and Description
protected List<SchemaPath>	columns
protected LogicalExpression	filter
protected ParquetReaderConfig	readerConfig
protected List<RowGroupReadEntry>	rowGroupReadEntries
protected TupleMetadata	schema
protected org.apache.hadoop.fs.Path	selectionRoot

Fields inherited from class org.apache.drill.exec.physical.base.AbstractBase

INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractParquetRowGroupScan(String userName, List<RowGroupReadEntry> rowGroupReadEntries, List<SchemaPath> columns, ParquetReaderConfig readerConfig, LogicalExpression filter, org.apache.hadoop.fs.Path selectionRoot, TupleMetadata schema)

Method Summary

Modifier and Type	Method and Description
<T,X,E extends Throwable> T	accept(PhysicalVisitor<T,X,E> physicalVisitor, X value) Provides capability to build a set of output based on traversing a query graph tree.
abstract AbstractParquetRowGroupScan	copy(List<SchemaPath> columns)
List<SchemaPath>	getColumns()
LogicalExpression	getFilter()
abstract org.apache.hadoop.conf.Configuration	getFsConf(RowGroupReadEntry rowGroupReadEntry)
abstract List<String>	getPartitionValues(RowGroupReadEntry rowGroupReadEntry)
ParquetReaderConfig	getReaderConfig()
ParquetReaderConfig	getReaderConfigForSerialization()
List<RowGroupReadEntry>	getRowGroupReadEntries()
TupleMetadata	getSchema()
org.apache.hadoop.fs.Path	getSelectionRoot()
boolean	isExecutable() Describes whether or not a particular physical operator can actually be executed.
Iterator<PhysicalOperator>	iterator()
abstract boolean	supportsFileImplicitColumns()

Methods inherited from class org.apache.drill.exec.physical.base.AbstractBase

accept, getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getSVMode, getUserName, isBufferedOperator, setCost, setMaxAllocation, setOperatorId

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.exec.physical.base.PhysicalOperator

getCost, getInitialAllocation, getMaxAllocation, getNewWithChildren, getOperatorId, getOperatorType, getSVMode, getUserName, isBufferedOperator, setCost, setMaxAllocation, setOperatorId

Methods inherited from interface org.apache.drill.common.graph.GraphValue

accept

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

rowGroupReadEntries

protected final List<RowGroupReadEntry> rowGroupReadEntries

columns

protected final List<SchemaPath> columns

readerConfig

protected final ParquetReaderConfig readerConfig

filter

protected final LogicalExpression filter

selectionRoot

protected final org.apache.hadoop.fs.Path selectionRoot

schema

protected final TupleMetadata schema

Constructor Detail

AbstractParquetRowGroupScan

protected AbstractParquetRowGroupScan(String userName,
                                      List<RowGroupReadEntry> rowGroupReadEntries,
                                      List<SchemaPath> columns,
                                      ParquetReaderConfig readerConfig,
                                      LogicalExpression filter,
                                      org.apache.hadoop.fs.Path selectionRoot,
                                      TupleMetadata schema)

Method Detail

getRowGroupReadEntries

public List<RowGroupReadEntry> getRowGroupReadEntries()

getColumns

public List<SchemaPath> getColumns()

getReaderConfigForSerialization

public ParquetReaderConfig getReaderConfigForSerialization()

getReaderConfig

public ParquetReaderConfig getReaderConfig()

getFilter

public LogicalExpression getFilter()

isExecutable

public boolean isExecutable()

Description copied from interface: PhysicalOperator

Describes whether or not a particular physical operator can actually be executed. Most physical operators can be executed. However, Exchange nodes cannot be executed. In order to be executed, they must be converted into their Exec sub components.

Specified by:

isExecutable in interface PhysicalOperator

Overrides:

isExecutable in class AbstractBase

accept

public <T,X,E extends Throwable> T accept(PhysicalVisitor<T,X,E> physicalVisitor,
                                          X value)
                                   throws E extends Throwable

Description copied from interface: PhysicalOperator

Provides capability to build a set of output based on traversing a query graph tree.

Specified by:

accept in interface PhysicalOperator

Throws:

E extends Throwable

iterator

public Iterator<PhysicalOperator> iterator()

Specified by:

iterator in interface Iterable<PhysicalOperator>

getSelectionRoot

public org.apache.hadoop.fs.Path getSelectionRoot()

getSchema

public TupleMetadata getSchema()

copy

public abstract AbstractParquetRowGroupScan copy(List<SchemaPath> columns)

getFsConf

public abstract org.apache.hadoop.conf.Configuration getFsConf(RowGroupReadEntry rowGroupReadEntry)
                                                        throws IOException

Throws:

IOException

supportsFileImplicitColumns

public abstract boolean supportsFileImplicitColumns()

getPartitionValues

public abstract List<String> getPartitionValues(RowGroupReadEntry rowGroupReadEntry)