Package 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:

DeltaRowGroupScan, HiveDrillNativeParquetRowGroupScan, ParquetRowGroupScan

public abstract class AbstractParquetRowGroupScan
extends AbstractBase
implements SubScan

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<SchemaPath>	columns
protected final LogicalExpression	filter
protected final ParquetReaderConfig	readerConfig
protected final List<RowGroupReadEntry>	rowGroupReadEntries
protected final TupleMetadata	schema
protected final 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	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	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.
boolean	isImplicitColumn(SchemaPath path, String partitionColumnLabel)
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.common.graph.GraphValue

accept

Methods inherited from interface java.lang.Iterable

forEach, spliterator

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

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

Field Details

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 Details

AbstractParquetRowGroupScan

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

Method Details

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

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

Parameters:

physicalVisitor -

Throws:

E

iterator

public Iterator<PhysicalOperator> iterator()

Specified by:

iterator in interface Iterable<PhysicalOperator>

getSelectionRoot

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

getSchema

public TupleMetadata getSchema()

isImplicitColumn

public boolean isImplicitColumn(SchemaPath path,
 String partitionColumnLabel)

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)