org.apache.druid.sql.calcite.rel

Class DruidRel<T extends DruidRel>

java.lang.Object

org.apache.calcite.rel.AbstractRelNode

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

All Implemented Interfaces:

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

Direct Known Subclasses:

DruidJoinQueryRel, DruidOuterQueryRel, DruidQueryRel, DruidUnionDataSourceRel, DruidUnionRel

public abstract class DruidRel<T extends DruidRel>
extends org.apache.calcite.rel.AbstractRelNode

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DruidRel(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traitSet, PlannerContext plannerContext)

Method Summary

Modifier and Type	Method and Description
abstract T	asDruidConvention()
abstract Set<String>	getDataSourceNames() Get the set of names of table datasources read by this DruidRel
abstract PartialDruidQuery	getPartialDruidQuery() Returns the PartialDruidQuery associated with this DruidRel, and which can be built on top of.
PlannerContext	getPlannerContext()
boolean	isValidDruidQuery()
Sequence<Object[]>	runQuery()
abstract DruidQuery	toDruidQuery(boolean finalizeAggregations) Convert this DruidRel to a DruidQuery.
abstract DruidQuery	toDruidQueryForExplaining() Convert this DruidRel to a DruidQuery for purposes of explaining.
abstract T	withPartialQuery(PartialDruidQuery newQueryBuilder)

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

accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeDigest, computeSelfCost, computeSelfCost, copy, deriveRowType, equals, estimateRowCount, explain, explainTerms, getChildExps, getCluster, getCollationList, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getTable, 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

Constructor Detail

DruidRel

protected DruidRel(org.apache.calcite.plan.RelOptCluster cluster,
                   org.apache.calcite.plan.RelTraitSet traitSet,
                   PlannerContext plannerContext)

Method Detail

getPartialDruidQuery

@Nullable
public abstract PartialDruidQuery getPartialDruidQuery()

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.

runQuery

public Sequence<Object[]> runQuery()

withPartialQuery

public abstract T withPartialQuery(PartialDruidQuery newQueryBuilder)

isValidDruidQuery

public boolean isValidDruidQuery()

toDruidQuery

public abstract DruidQuery toDruidQuery(boolean finalizeAggregations)

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.

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.

Throws:

CannotBuildQueryException

toDruidQueryForExplaining

public abstract DruidQuery toDruidQueryForExplaining()

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

Throws:

CannotBuildQueryException

getPlannerContext

public PlannerContext getPlannerContext()

asDruidConvention

public abstract T asDruidConvention()

getDataSourceNames

public abstract Set<String> getDataSourceNames()

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