org.apache.druid.sql.calcite.rel

Class PartialDruidQuery

java.lang.Object

org.apache.druid.sql.calcite.rel.PartialDruidQuery

public class PartialDruidQuery
extends Object

Builder for a Druid query, not counting the "dataSource" (which will be slotted in later).

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PartialDruidQuery.Stage

Method Summary

Modifier and Type	Method and Description
DruidQuery	build(DataSource dataSource, RowSignature sourceRowSignature, PlannerContext plannerContext, org.apache.calcite.rex.RexBuilder rexBuilder, boolean finalizeAggregations)
DruidQuery	build(DataSource dataSource, RowSignature sourceRowSignature, PlannerContext plannerContext, org.apache.calcite.rex.RexBuilder rexBuilder, boolean finalizeAggregations, VirtualColumnRegistry virtualColumnRegistry)
boolean	canAccept(PartialDruidQuery.Stage stage)
static PartialDruidQuery	create(org.apache.calcite.rel.RelNode scanRel)
boolean	equals(Object o)
double	estimateCost() Estimates the per-row cost of running this query.
org.apache.calcite.rel.core.Aggregate	getAggregate()
org.apache.calcite.rel.core.Project	getAggregateProject()
org.apache.calcite.rel.core.Filter	getHavingFilter()
org.apache.calcite.plan.RelTrait[]	getRelTraits()
org.apache.calcite.rel.type.RelDataType	getRowType()
org.apache.calcite.rel.RelNode	getScan()
org.apache.calcite.rel.core.Project	getSelectProject()
org.apache.calcite.rel.core.Sort	getSort()
org.apache.calcite.rel.core.Project	getSortProject()
org.apache.calcite.rel.core.Filter	getWhereFilter()
int	hashCode()
org.apache.calcite.rel.RelNode	leafRel() Returns the rel at the end of the query.
PartialDruidQuery.Stage	stage() Returns the stage corresponding to the rel at the end of the query.
String	toString()
PartialDruidQuery	withAggregate(org.apache.calcite.rel.core.Aggregate newAggregate)
PartialDruidQuery	withAggregateProject(org.apache.calcite.rel.core.Project newAggregateProject)
PartialDruidQuery	withHavingFilter(org.apache.calcite.rel.core.Filter newHavingFilter)
PartialDruidQuery	withSelectProject(org.apache.calcite.rel.core.Project newSelectProject)
PartialDruidQuery	withSort(org.apache.calcite.rel.core.Sort newSort)
PartialDruidQuery	withSortProject(org.apache.calcite.rel.core.Project newSortProject)
PartialDruidQuery	withWhereFilter(org.apache.calcite.rel.core.Filter newWhereFilter)

Methods inherited from class java.lang.Object

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

Method Detail

create

public static PartialDruidQuery create(org.apache.calcite.rel.RelNode scanRel)

getScan

public org.apache.calcite.rel.RelNode getScan()

getWhereFilter

public org.apache.calcite.rel.core.Filter getWhereFilter()

getSelectProject

public org.apache.calcite.rel.core.Project getSelectProject()

getAggregate

public org.apache.calcite.rel.core.Aggregate getAggregate()

getHavingFilter

public org.apache.calcite.rel.core.Filter getHavingFilter()

getAggregateProject

public org.apache.calcite.rel.core.Project getAggregateProject()

getSort

public org.apache.calcite.rel.core.Sort getSort()

getSortProject

public org.apache.calcite.rel.core.Project getSortProject()

withWhereFilter

public PartialDruidQuery withWhereFilter(org.apache.calcite.rel.core.Filter newWhereFilter)

withSelectProject

public PartialDruidQuery withSelectProject(org.apache.calcite.rel.core.Project newSelectProject)

withAggregate

public PartialDruidQuery withAggregate(org.apache.calcite.rel.core.Aggregate newAggregate)

withHavingFilter

public PartialDruidQuery withHavingFilter(org.apache.calcite.rel.core.Filter newHavingFilter)

withAggregateProject

public PartialDruidQuery withAggregateProject(org.apache.calcite.rel.core.Project newAggregateProject)

withSort

public PartialDruidQuery withSort(org.apache.calcite.rel.core.Sort newSort)

withSortProject

public PartialDruidQuery withSortProject(org.apache.calcite.rel.core.Project newSortProject)

getRowType

public org.apache.calcite.rel.type.RelDataType getRowType()

getRelTraits

public org.apache.calcite.plan.RelTrait[] getRelTraits()

build

public DruidQuery build(DataSource dataSource,
                        RowSignature sourceRowSignature,
                        PlannerContext plannerContext,
                        org.apache.calcite.rex.RexBuilder rexBuilder,
                        boolean finalizeAggregations)

build

public DruidQuery build(DataSource dataSource,
                        RowSignature sourceRowSignature,
                        PlannerContext plannerContext,
                        org.apache.calcite.rex.RexBuilder rexBuilder,
                        boolean finalizeAggregations,
                        @Nullable
                        VirtualColumnRegistry virtualColumnRegistry)

canAccept

public boolean canAccept(PartialDruidQuery.Stage stage)

stage

public PartialDruidQuery.Stage stage()

Returns the stage corresponding to the rel at the end of the query. It will match the rel returned from leafRel().

Returns:

stage

leafRel

public org.apache.calcite.rel.RelNode leafRel()

Returns the rel at the end of the query. It will match the stage returned from stage().

Returns:

leaf rel

estimateCost

public double estimateCost()

Estimates the per-row cost of running this query.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object