org.apache.druid.sql.calcite.rel

Class DruidJoinQueryRel

java.lang.Object

org.apache.calcite.rel.AbstractRelNode

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

org.apache.druid.sql.calcite.rel.DruidJoinQueryRel

All Implemented Interfaces:

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

public class DruidJoinQueryRel
extends DruidRel<DruidJoinQueryRel>

DruidRel that uses a JoinDataSource.

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
DruidJoinQueryRel	asDruidConvention()
static boolean	computeRightRequiresSubquery(DruidRel<?> right)
org.apache.calcite.plan.RelOptCost	computeSelfCost(org.apache.calcite.plan.RelOptPlanner planner, org.apache.calcite.rel.metadata.RelMetadataQuery mq)
org.apache.calcite.rel.RelNode	copy(org.apache.calcite.plan.RelTraitSet traitSet, List<org.apache.calcite.rel.RelNode> inputs)
static DruidJoinQueryRel	create(org.apache.calcite.rel.core.Join joinRel, org.apache.calcite.rel.core.Filter leftFilter, PlannerContext plannerContext) Create an instance from a Join that is based on two DruidRel inputs.
protected org.apache.calcite.rel.type.RelDataType	deriveRowType()
org.apache.calcite.rel.RelWriter	explainTerms(org.apache.calcite.rel.RelWriter pw)
List<org.apache.calcite.rex.RexNode>	getChildExps()
Set<String>	getDataSourceNames() Get the set of names of table datasources read by this DruidRel
List<org.apache.calcite.rel.RelNode>	getInputs()
PartialDruidQuery	getPartialDruidQuery() Returns the PartialDruidQuery associated with this DruidRel, and which can be built on top of.
static DruidRel<?>	getSomeDruidChild(org.apache.calcite.rel.RelNode child)
void	replaceInput(int ordinalInParent, org.apache.calcite.rel.RelNode p)
static JoinType	toDruidJoinType(org.apache.calcite.rel.core.JoinRelType calciteJoinType)
DruidQuery	toDruidQuery(boolean finalizeAggregations) Convert this DruidRel to a DruidQuery.
DruidQuery	toDruidQueryForExplaining() Convert this DruidRel to a DruidQuery for purposes of explaining.
DruidJoinQueryRel	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, equals, estimateRowCount, explain, getCluster, getCollationList, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getQuery, getRelTypeName, getRows, getRowType, getTable, getTraitSet, getVariablesSet, getVariablesStopped, hashCode, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, sole, toString

Methods inherited from class java.lang.Object

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

Method Detail

create

public static DruidJoinQueryRel create(org.apache.calcite.rel.core.Join joinRel,
                                       org.apache.calcite.rel.core.Filter leftFilter,
                                       PlannerContext plannerContext)

Create an instance from a Join that is based on two DruidRel inputs.

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<DruidJoinQueryRel>

withPartialQuery

public DruidJoinQueryRel withPartialQuery(PartialDruidQuery newQueryBuilder)

Specified by:

withPartialQuery in class DruidRel<DruidJoinQueryRel>

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<DruidJoinQueryRel>

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<DruidJoinQueryRel>

asDruidConvention

public DruidJoinQueryRel asDruidConvention()

Specified by:

asDruidConvention in class DruidRel<DruidJoinQueryRel>

getInputs

public List<org.apache.calcite.rel.RelNode> getInputs()

Specified by:

getInputs in interface org.apache.calcite.plan.RelOptNode

Specified by:

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

Overrides:

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

replaceInput

public void replaceInput(int ordinalInParent,
                         org.apache.calcite.rel.RelNode p)

Specified by:

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

Overrides:

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

getChildExps

public List<org.apache.calcite.rex.RexNode> getChildExps()

Specified by:

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

Overrides:

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

copy

public org.apache.calcite.rel.RelNode copy(org.apache.calcite.plan.RelTraitSet traitSet,
                                           List<org.apache.calcite.rel.RelNode> inputs)

Specified by:

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

Overrides:

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

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<DruidJoinQueryRel>

explainTerms

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

Overrides:

explainTerms 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

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

toDruidJoinType

public static JoinType toDruidJoinType(org.apache.calcite.rel.core.JoinRelType calciteJoinType)

computeRightRequiresSubquery

public static boolean computeRightRequiresSubquery(DruidRel<?> right)

getSomeDruidChild

public static DruidRel<?> getSomeDruidChild(org.apache.calcite.rel.RelNode child)