org.apache.drill.exec.planner.logical

Class DrillScanRel

java.lang.Object

org.apache.calcite.rel.AbstractRelNode

org.apache.calcite.rel.core.TableScan

org.apache.drill.exec.planner.common.DrillScanRelBase

org.apache.drill.exec.planner.logical.DrillScanRel

All Implemented Interfaces:

Cloneable, org.apache.calcite.plan.RelOptNode, org.apache.calcite.rel.RelNode, DrillRelNode, DrillRel

public class DrillScanRel
extends DrillScanRelBase
implements DrillRel

GroupScan of a Drill table.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.calcite.rel.RelNode

org.apache.calcite.rel.RelNode.Context

Field Summary

Fields

Modifier and Type	Field and Description
static int	STAR_COLUMN_COST

Fields inherited from class org.apache.drill.exec.planner.common.DrillScanRelBase

drillTable, groupScan

Fields inherited from class org.apache.calcite.rel.core.TableScan

table

Fields inherited from class org.apache.calcite.rel.AbstractRelNode

digest, id, traitSet

Fields inherited from interface org.apache.drill.exec.planner.logical.DrillRel

DRILL_LOGICAL

Constructor Summary

Constructors

Constructor and Description
DrillScanRel(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traits, org.apache.calcite.plan.RelOptTable table)
DrillScanRel(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traits, org.apache.calcite.plan.RelOptTable table, boolean partitionFilterPushdown)
DrillScanRel(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traits, org.apache.calcite.plan.RelOptTable table, GroupScan groupScan, org.apache.calcite.rel.type.RelDataType rowType, List<SchemaPath> columns) Creates a DrillScanRel for a particular GroupScan
DrillScanRel(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traits, org.apache.calcite.plan.RelOptTable table, GroupScan groupScan, org.apache.calcite.rel.type.RelDataType rowType, List<SchemaPath> columns, boolean partitionFilterPushdown) Creates a DrillScanRel for a particular GroupScan
DrillScanRel(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traits, org.apache.calcite.plan.RelOptTable table, org.apache.calcite.rel.type.RelDataType rowType, List<SchemaPath> columns)
DrillScanRel(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traits, org.apache.calcite.plan.RelOptTable table, org.apache.calcite.rel.type.RelDataType rowType, List<SchemaPath> columns, boolean partitionFilterPushdown)

Method Summary

Modifier and Type	Method and Description
org.apache.calcite.plan.RelOptCost	computeSelfCost(org.apache.calcite.plan.RelOptPlanner planner, org.apache.calcite.rel.metadata.RelMetadataQuery mq)
static DrillScanRel	convert(Scan scan, ConversionContext context)
DrillScanRel	copy(org.apache.calcite.plan.RelTraitSet traitSet, GroupScan scan)
org.apache.calcite.rel.type.RelDataType	deriveRowType()
double	estimateRowCount(org.apache.calcite.rel.metadata.RelMetadataQuery mq)
org.apache.calcite.rel.RelWriter	explainTerms(org.apache.calcite.rel.RelWriter pw)
List<SchemaPath>	getColumns()
static List<SchemaPath>	getProjectedColumns(org.apache.calcite.plan.RelOptTable table, boolean isSelectStar)
LogicalOperator	implement(DrillImplementor implementor)
boolean	partitionFilterPushdown()

Methods inherited from class org.apache.drill.exec.planner.common.DrillScanRelBase

getDrillTable, getGroupScan

Methods inherited from class org.apache.calcite.rel.core.TableScan

accept, getCollationList, getTable, identity, identity, project

Methods inherited from class org.apache.calcite.rel.AbstractRelNode

accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeDigest, computeSelfCost, copy, equals, explain, getChildExps, getCluster, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getTraitSet, getVariablesSet, getVariablesStopped, hashCode, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, replaceInput, sole, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.calcite.rel.RelNode

accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, copy, explain, getChildExps, getCollationList, getConvention, getCorrelVariable, getExpectedInputRowType, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getTable, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, replaceInput

Methods inherited from interface org.apache.calcite.plan.RelOptNode

getCluster, getDescription, getDigest, getId, getTraitSet

Field Detail

STAR_COLUMN_COST

public static final int STAR_COLUMN_COST

See Also:

Constant Field Values

Constructor Detail

DrillScanRel

public DrillScanRel(org.apache.calcite.plan.RelOptCluster cluster,
                    org.apache.calcite.plan.RelTraitSet traits,
                    org.apache.calcite.plan.RelOptTable table)

DrillScanRel

public DrillScanRel(org.apache.calcite.plan.RelOptCluster cluster,
                    org.apache.calcite.plan.RelTraitSet traits,
                    org.apache.calcite.plan.RelOptTable table,
                    boolean partitionFilterPushdown)

DrillScanRel

public DrillScanRel(org.apache.calcite.plan.RelOptCluster cluster,
                    org.apache.calcite.plan.RelTraitSet traits,
                    org.apache.calcite.plan.RelOptTable table,
                    org.apache.calcite.rel.type.RelDataType rowType,
                    List<SchemaPath> columns)

DrillScanRel

public DrillScanRel(org.apache.calcite.plan.RelOptCluster cluster,
                    org.apache.calcite.plan.RelTraitSet traits,
                    org.apache.calcite.plan.RelOptTable table,
                    org.apache.calcite.rel.type.RelDataType rowType,
                    List<SchemaPath> columns,
                    boolean partitionFilterPushdown)

DrillScanRel

public DrillScanRel(org.apache.calcite.plan.RelOptCluster cluster,
                    org.apache.calcite.plan.RelTraitSet traits,
                    org.apache.calcite.plan.RelOptTable table,
                    GroupScan groupScan,
                    org.apache.calcite.rel.type.RelDataType rowType,
                    List<SchemaPath> columns)

Creates a DrillScanRel for a particular GroupScan

DrillScanRel

public DrillScanRel(org.apache.calcite.plan.RelOptCluster cluster,
                    org.apache.calcite.plan.RelTraitSet traits,
                    org.apache.calcite.plan.RelOptTable table,
                    GroupScan groupScan,
                    org.apache.calcite.rel.type.RelDataType rowType,
                    List<SchemaPath> columns,
                    boolean partitionFilterPushdown)

Creates a DrillScanRel for a particular GroupScan

Method Detail

getColumns

public List<SchemaPath> getColumns()

implement

public LogicalOperator implement(DrillImplementor implementor)

Specified by:

implement in interface DrillRel

convert

public static DrillScanRel convert(Scan scan,
                                   ConversionContext context)

deriveRowType

public org.apache.calcite.rel.type.RelDataType deriveRowType()

Overrides:

deriveRowType in class org.apache.calcite.rel.core.TableScan

explainTerms

public org.apache.calcite.rel.RelWriter explainTerms(org.apache.calcite.rel.RelWriter pw)

Overrides:

explainTerms in class org.apache.calcite.rel.core.TableScan

estimateRowCount

public double estimateRowCount(org.apache.calcite.rel.metadata.RelMetadataQuery mq)

Specified by:

estimateRowCount in interface org.apache.calcite.rel.RelNode

Overrides:

estimateRowCount in class DrillScanRelBase

computeSelfCost

public org.apache.calcite.plan.RelOptCost computeSelfCost(org.apache.calcite.plan.RelOptPlanner planner,
                                                          org.apache.calcite.rel.metadata.RelMetadataQuery mq)

Specified by:

computeSelfCost in interface org.apache.calcite.rel.RelNode

Overrides:

computeSelfCost in class DrillScanRelBase

partitionFilterPushdown

public boolean partitionFilterPushdown()

getProjectedColumns

public static List<SchemaPath> getProjectedColumns(org.apache.calcite.plan.RelOptTable table,
                                                   boolean isSelectStar)

copy

public DrillScanRel copy(org.apache.calcite.plan.RelTraitSet traitSet,
                         GroupScan scan)

Specified by:

copy in class DrillScanRelBase