io.druid.sql.calcite.rel

Class DruidRel<T extends DruidRel>

java.lang.Object

org.apache.calcite.rel.AbstractRelNode

io.druid.sql.calcite.rel.DruidRel<T>

All Implemented Interfaces:

Cloneable, org.apache.calcite.interpreter.BindableRel, org.apache.calcite.interpreter.InterpretableRel, org.apache.calcite.plan.RelOptNode, org.apache.calcite.rel.RelNode, org.apache.calcite.runtime.ArrayBindable, org.apache.calcite.runtime.Bindable<Object[]>, org.apache.calcite.runtime.Typed

Direct Known Subclasses:

DruidNestedGroupBy, DruidQueryRel, DruidSemiJoin

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

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.calcite.interpreter.InterpretableRel

org.apache.calcite.interpreter.InterpretableRel.InterpreterImplementor

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

Constructor and Description
DruidRel(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traitSet, QueryMaker queryMaker)

Method Summary

Modifier and Type	Method and Description
abstract T	asBindable()
abstract QueryDataSource	asDataSource() Convert this DruidRel to a QueryDataSource, for embedding in some other outer query.
abstract T	asDruidConvention()
org.apache.calcite.linq4j.Enumerable<Object[]>	bind(org.apache.calcite.DataContext dataContext)
Class<Object[]>	getElementType()
RowSignature	getOutputRowSignature()
PlannerContext	getPlannerContext()
abstract DruidQueryBuilder	getQueryBuilder()
abstract int	getQueryCount() Return the number of Druid queries this rel involves, including sub-queries.
QueryMaker	getQueryMaker()
abstract RowSignature	getSourceRowSignature()
org.apache.calcite.interpreter.Node	implement(org.apache.calcite.interpreter.InterpretableRel.InterpreterImplementor implementor)
abstract Sequence<Object[]>	runQuery()
abstract T	withQueryBuilder(DruidQueryBuilder newQueryBuilder)

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

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

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

accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, computeSelfCost, copy, estimateRowCount, 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

Constructor Detail

DruidRel

public DruidRel(org.apache.calcite.plan.RelOptCluster cluster,
                org.apache.calcite.plan.RelTraitSet traitSet,
                QueryMaker queryMaker)

Method Detail

getSourceRowSignature

public abstract RowSignature getSourceRowSignature()

getOutputRowSignature

public final RowSignature getOutputRowSignature()

getQueryBuilder

public abstract DruidQueryBuilder getQueryBuilder()

getQueryCount

public abstract int getQueryCount()

Return the number of Druid queries this rel involves, including sub-queries. Simple queries will return 1.

Returns:

number of nested queries

runQuery

public abstract Sequence<Object[]> runQuery()

withQueryBuilder

public abstract T withQueryBuilder(DruidQueryBuilder newQueryBuilder)

asDataSource

public abstract QueryDataSource asDataSource()

Convert this DruidRel to a QueryDataSource, for embedding in some other outer query. This may be an expensive operation. For example, DruidSemiJoin needs to execute the right-hand side query in order to complete this method. This method may return null if it knows that this rel will yield an empty result set.

Returns:

query dataSource, or null if it is known in advance that this rel will yield an empty result set.

asBindable

public abstract T asBindable()

getQueryMaker

public QueryMaker getQueryMaker()

getPlannerContext

public PlannerContext getPlannerContext()

asDruidConvention

public abstract T asDruidConvention()

getElementType

public Class<Object[]> getElementType()

Specified by:

getElementType in interface org.apache.calcite.runtime.ArrayBindable

Specified by:

getElementType in interface org.apache.calcite.runtime.Typed

implement

public org.apache.calcite.interpreter.Node implement(org.apache.calcite.interpreter.InterpretableRel.InterpreterImplementor implementor)

Specified by:

implement in interface org.apache.calcite.interpreter.InterpretableRel

bind

public org.apache.calcite.linq4j.Enumerable<Object[]> bind(org.apache.calcite.DataContext dataContext)

Specified by:

bind in interface org.apache.calcite.runtime.Bindable<Object[]>