io.druid.sql.calcite.rel

Class DruidNestedGroupBy

java.lang.Object

org.apache.calcite.rel.AbstractRelNode

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

io.druid.sql.calcite.rel.DruidNestedGroupBy

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

public class DruidNestedGroupBy
extends DruidRel<DruidNestedGroupBy>

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

Method Summary

Modifier and Type	Method and Description
DruidNestedGroupBy	asBindable()
QueryDataSource	asDataSource() Convert this DruidRel to a QueryDataSource, for embedding in some other outer query.
DruidNestedGroupBy	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)
static DruidNestedGroupBy	from(DruidRel sourceRel, DimFilter filter, Grouping grouping, org.apache.calcite.rel.type.RelDataType rowType, List<String> rowOrder)
DruidQueryBuilder	getQueryBuilder()
int	getQueryCount() Return the number of Druid queries this rel involves, including sub-queries.
RowSignature	getSourceRowSignature()
Sequence<Object[]>	runQuery()
DruidNestedGroupBy	withQueryBuilder(DruidQueryBuilder newQueryBuilder)

Methods inherited from class io.druid.sql.calcite.rel.DruidRel

bind, getElementType, getOutputRowSignature, getPlannerContext, getQueryMaker, implement

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

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

Method Detail

from

public static DruidNestedGroupBy from(DruidRel sourceRel,
                                      DimFilter filter,
                                      Grouping grouping,
                                      org.apache.calcite.rel.type.RelDataType rowType,
                                      List<String> rowOrder)

getSourceRowSignature

public RowSignature getSourceRowSignature()

Specified by:

getSourceRowSignature in class DruidRel<DruidNestedGroupBy>

getQueryBuilder

public DruidQueryBuilder getQueryBuilder()

Specified by:

getQueryBuilder in class DruidRel<DruidNestedGroupBy>

runQuery

public Sequence<Object[]> runQuery()

Specified by:

runQuery in class DruidRel<DruidNestedGroupBy>

withQueryBuilder

public DruidNestedGroupBy withQueryBuilder(DruidQueryBuilder newQueryBuilder)

Specified by:

withQueryBuilder in class DruidRel<DruidNestedGroupBy>

getQueryCount

public int getQueryCount()

Description copied from class: DruidRel

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

Specified by:

getQueryCount in class DruidRel<DruidNestedGroupBy>

Returns:

number of nested queries

asDataSource

public QueryDataSource asDataSource()

Description copied from class: DruidRel

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.

Specified by:

asDataSource in class DruidRel<DruidNestedGroupBy>

Returns:

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

asBindable

public DruidNestedGroupBy asBindable()

Specified by:

asBindable in class DruidRel<DruidNestedGroupBy>

asDruidConvention

public DruidNestedGroupBy asDruidConvention()

Specified by:

asDruidConvention in class DruidRel<DruidNestedGroupBy>

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