org.apache.druid.sql.calcite.rel

Class DruidQueryRel

java.lang.Object

org.apache.calcite.rel.AbstractRelNode

org.apache.druid.sql.calcite.rel.DruidRel<DruidQueryRel>

org.apache.druid.sql.calcite.rel.DruidQueryRel

All Implemented Interfaces:

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

public class DruidQueryRel
extends DruidRel<DruidQueryRel>

DruidRel that operates on top of a DruidTable directly (no joining or subqueries).

Nested Class Summary

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

org.apache.calcite.rel.RelNode.Context

Field Summary

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

digest, id, rowType, traitSet

Method Summary

Modifier and Type	Method and Description
DruidQueryRel	asDruidConvention()
org.apache.calcite.plan.RelOptCost	computeSelfCost(org.apache.calcite.plan.RelOptPlanner planner, org.apache.calcite.rel.metadata.RelMetadataQuery mq)
protected org.apache.calcite.rel.type.RelDataType	deriveRowType()
org.apache.calcite.rel.RelWriter	explainTerms(org.apache.calcite.rel.RelWriter pw)
Set<String>	getDataSourceNames() Get the set of names of table datasources read by this DruidRel
DruidTable	getDruidTable()
PartialDruidQuery	getPartialDruidQuery() Returns the PartialDruidQuery associated with this DruidRel, and which can be built on top of.
org.apache.calcite.plan.RelOptTable	getTable()
static DruidQueryRel	scanExternal(ExternalTableScan scanRel, PlannerContext plannerContext) Create a DruidQueryRel representing a full scan of external data.
static DruidQueryRel	scanTable(org.apache.calcite.rel.logical.LogicalTableScan scanRel, org.apache.calcite.plan.RelOptTable table, DruidTable druidTable, PlannerContext plannerContext) Create a DruidQueryRel representing a full scan of a builtin table or lookup.
static DruidQueryRel	scanValues(org.apache.calcite.rel.logical.LogicalValues valuesRel, DruidTable druidTable, PlannerContext plannerContext) Create a DruidQueryRel representing a full scan of inline, literal values.
DruidQuery	toDruidQuery(boolean finalizeAggregations) Convert this DruidRel to a DruidQuery.
DruidQuery	toDruidQueryForExplaining() Convert this DruidRel to a DruidQuery for purposes of explaining.
DruidQueryRel	withPartialQuery(PartialDruidQuery newQueryBuilder)

Methods inherited from class org.apache.druid.sql.calcite.rel.DruidRel

getPlannerContext, isValidDruidQuery, runQuery

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

accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeDigest, computeSelfCost, copy, equals, estimateRowCount, explain, getChildExps, getCluster, getCollationList, 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

Method Detail

scanTable

public static DruidQueryRel scanTable(org.apache.calcite.rel.logical.LogicalTableScan scanRel,
                                      org.apache.calcite.plan.RelOptTable table,
                                      DruidTable druidTable,
                                      PlannerContext plannerContext)

Create a DruidQueryRel representing a full scan of a builtin table or lookup.

scanExternal

public static DruidQueryRel scanExternal(ExternalTableScan scanRel,
                                         PlannerContext plannerContext)

Create a DruidQueryRel representing a full scan of external data.

scanValues

public static DruidQueryRel scanValues(org.apache.calcite.rel.logical.LogicalValues valuesRel,
                                       DruidTable druidTable,
                                       PlannerContext plannerContext)

Create a DruidQueryRel representing a full scan of inline, literal values.

toDruidQuery

public DruidQuery toDruidQuery(boolean finalizeAggregations)

Description copied from class: DruidRel

Convert this DruidRel to a DruidQuery. This must be an inexpensive operation, since it is done often throughout query planning. This method must not return null.

Specified by:

toDruidQuery in class DruidRel<DruidQueryRel>

Parameters:

finalizeAggregations - true if this query should include explicit finalization for all of its aggregators, where required. Useful for subqueries where Druid's native query layer does not do this automatically.

toDruidQueryForExplaining

public DruidQuery toDruidQueryForExplaining()

Description copied from class: DruidRel

Convert this DruidRel to a DruidQuery for purposes of explaining. This must be an inexpensive operation. This method must not return null.

Specified by:

toDruidQueryForExplaining in class DruidRel<DruidQueryRel>

asDruidConvention

public DruidQueryRel asDruidConvention()

Specified by:

asDruidConvention in class DruidRel<DruidQueryRel>

getDataSourceNames

public Set<String> getDataSourceNames()

Description copied from class: DruidRel

Get the set of names of table datasources read by this DruidRel

Specified by:

getDataSourceNames in class DruidRel<DruidQueryRel>

getPartialDruidQuery

public PartialDruidQuery getPartialDruidQuery()

Description copied from class: DruidRel

Returns the PartialDruidQuery associated with this DruidRel, and which can be built on top of. Returns null if this rel cannot be built on top of.

Specified by:

getPartialDruidQuery in class DruidRel<DruidQueryRel>

withPartialQuery

public DruidQueryRel withPartialQuery(PartialDruidQuery newQueryBuilder)

Specified by:

withPartialQuery in class DruidRel<DruidQueryRel>

getDruidTable

public DruidTable getDruidTable()

getTable

public org.apache.calcite.plan.RelOptTable getTable()

Specified by:

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

Overrides:

getTable in class org.apache.calcite.rel.AbstractRelNode

deriveRowType

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

Overrides:

deriveRowType in class org.apache.calcite.rel.AbstractRelNode

explainTerms

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

Overrides:

explainTerms in class org.apache.calcite.rel.AbstractRelNode

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 org.apache.calcite.rel.AbstractRelNode