Package org.apache.druid.sql.calcite.rel

Class DruidQuery

java.lang.Object

org.apache.druid.sql.calcite.rel.DruidQuery

public class DruidQuery
extends Object

A fully formed Druid query, built from a PartialDruidQuery. The work to develop this query is done during construction, which may throw CannotBuildQueryException.

Method Summary

Modifier and Type	Method	Description
static Grouping	buildGrouping(org.apache.calcite.rel.core.Aggregate aggregate, org.apache.calcite.rel.core.Project selectProject, org.apache.calcite.rel.core.Filter havingFilterRel, PlannerContext plannerContext, RowSignature rowSignature, VirtualColumnRegistry virtualColumnRegistry, boolean finalizeAggregations)
static List<OrderByColumnSpec>	buildOrderByColumnSpecs(RowSignature rowSignature, org.apache.calcite.rel.core.Sort sort)
static DruidQuery	fromPartialQuery(PartialDruidQuery partialQuery, DataSource dataSource, RowSignature sourceRowSignature, PlannerContext plannerContext, org.apache.calcite.rex.RexBuilder rexBuilder, boolean finalizeAggregations, boolean applyPolicies, VirtualColumnRegistry virtualColumnRegistry)
static List<DimFilter>	getAllFiltersUnderDataSource(DataSource d, List<DimFilter> dimFilterList)
DataSource	getDataSource()
static DimFilter	getDimFilter(PlannerContext plannerContext, RowSignature rowSignature, VirtualColumnRegistry virtualColumnRegistry, org.apache.calcite.rel.core.Filter filter)
DimFilter	getFilter()
Grouping	getGrouping()
RowSignature	getOutputRowSignature()
org.apache.calcite.rel.type.RelDataType	getOutputRowType()
Query<?>	getQuery()

Methods inherited from class java.lang.Object

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

Method Details

fromPartialQuery

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

getDimFilter

@Nonnull
public static DimFilter getDimFilter(PlannerContext plannerContext,
 RowSignature rowSignature,
 @Nullable
 VirtualColumnRegistry virtualColumnRegistry,
 org.apache.calcite.rel.core.Filter filter)

buildGrouping

public static Grouping buildGrouping(org.apache.calcite.rel.core.Aggregate aggregate,
 org.apache.calcite.rel.core.Project selectProject,
 org.apache.calcite.rel.core.Filter havingFilterRel,
 PlannerContext plannerContext,
 RowSignature rowSignature,
 VirtualColumnRegistry virtualColumnRegistry,
 boolean finalizeAggregations)

buildOrderByColumnSpecs

public static List<OrderByColumnSpec> buildOrderByColumnSpecs(RowSignature rowSignature,
 org.apache.calcite.rel.core.Sort sort)

getAllFiltersUnderDataSource

public static List<DimFilter> getAllFiltersUnderDataSource(DataSource d,
 List<DimFilter> dimFilterList)

getDataSource

public DataSource getDataSource()

getGrouping

@Nullable
public Grouping getGrouping()

getOutputRowType

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

getOutputRowSignature

public RowSignature getOutputRowSignature()

getQuery

public Query<?> getQuery()

getFilter

public DimFilter getFilter()