io.druid.sql.calcite.rel

Class DruidQueryBuilder

java.lang.Object

io.druid.sql.calcite.rel.DruidQueryBuilder

public class DruidQueryBuilder
extends Object

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
static DruidQueryBuilder	fullScan(RowSignature rowSignature, org.apache.calcite.rel.type.RelDataTypeFactory relDataTypeFactory)
DimFilter	getFilter()
Grouping	getGrouping()
DimFilter	getHaving()
DefaultLimitSpec	getLimitSpec()
RowSignature	getOutputRowSignature() Returns the output row signature for this DruidQueryBuilder.
org.apache.calcite.plan.RelTrait[]	getRelTraits()
List<String>	getRowOrder()
org.apache.calcite.rel.type.RelDataType	getRowType()
SelectProjection	getSelectProjection()
int	hashCode()
GroupByQuery	toGroupByQuery(DataSource dataSource, RowSignature sourceRowSignature, Map<String,Object> context) Return this query as a GroupBy query, or null if this query is not compatible with GroupBy.
SelectQuery	toSelectQuery(DataSource dataSource, RowSignature sourceRowSignature, Map<String,Object> context) Return this query as a Select query, or null if this query is not compatible with Select.
String	toString()
TimeseriesQuery	toTimeseriesQuery(DataSource dataSource, RowSignature sourceRowSignature, Map<String,Object> context) Return this query as a Timeseries query, or null if this query is not compatible with Timeseries.
TopNQuery	toTopNQuery(DataSource dataSource, RowSignature sourceRowSignature, Map<String,Object> context, int maxTopNLimit, boolean useApproximateTopN) Return this query as a TopN query, or null if this query is not compatible with TopN.
DruidQueryBuilder	withAdjustedGrouping(Grouping newGrouping, org.apache.calcite.rel.type.RelDataType newRowType, List<String> newRowOrder)
DruidQueryBuilder	withFilter(DimFilter newFilter)
DruidQueryBuilder	withGrouping(Grouping newGrouping, org.apache.calcite.rel.type.RelDataType newRowType, List<String> newRowOrder)
DruidQueryBuilder	withHaving(DimFilter newHaving)
DruidQueryBuilder	withLimitSpec(DefaultLimitSpec newLimitSpec)
DruidQueryBuilder	withSelectProjection(SelectProjection newProjection, List<String> newRowOrder)

Methods inherited from class java.lang.Object

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

Method Detail

fullScan

public static DruidQueryBuilder fullScan(RowSignature rowSignature,
                                         org.apache.calcite.rel.type.RelDataTypeFactory relDataTypeFactory)

withFilter

public DruidQueryBuilder withFilter(DimFilter newFilter)

withSelectProjection

public DruidQueryBuilder withSelectProjection(SelectProjection newProjection,
                                              List<String> newRowOrder)

withGrouping

public DruidQueryBuilder withGrouping(Grouping newGrouping,
                                      org.apache.calcite.rel.type.RelDataType newRowType,
                                      List<String> newRowOrder)

withAdjustedGrouping

public DruidQueryBuilder withAdjustedGrouping(Grouping newGrouping,
                                              org.apache.calcite.rel.type.RelDataType newRowType,
                                              List<String> newRowOrder)

withHaving

public DruidQueryBuilder withHaving(DimFilter newHaving)

withLimitSpec

public DruidQueryBuilder withLimitSpec(DefaultLimitSpec newLimitSpec)

getFilter

public DimFilter getFilter()

getSelectProjection

public SelectProjection getSelectProjection()

getGrouping

public Grouping getGrouping()

getHaving

public DimFilter getHaving()

getLimitSpec

public DefaultLimitSpec getLimitSpec()

getOutputRowSignature

public RowSignature getOutputRowSignature()

Returns the output row signature for this DruidQueryBuilder. Useful if we will go on to do something else with the rows, like make a QueryDataSource or use a HavingSpec. Note that the field names may be different from the field names returned by getRowType(), although positionally they will line up.

Returns:

Druid row signature

getRowType

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

getRowOrder

public List<String> getRowOrder()

getRelTraits

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

toTimeseriesQuery

public TimeseriesQuery toTimeseriesQuery(DataSource dataSource,
                                         RowSignature sourceRowSignature,
                                         Map<String,Object> context)

Return this query as a Timeseries query, or null if this query is not compatible with Timeseries.

Parameters:

dataSource - data source to query

sourceRowSignature - row signature of the dataSource

context - query context

Returns:

query or null

toTopNQuery

public TopNQuery toTopNQuery(DataSource dataSource,
                             RowSignature sourceRowSignature,
                             Map<String,Object> context,
                             int maxTopNLimit,
                             boolean useApproximateTopN)

Return this query as a TopN query, or null if this query is not compatible with TopN.

Parameters:

dataSource - data source to query

sourceRowSignature - row signature of the dataSource

context - query context

maxTopNLimit - maxTopNLimit from a PlannerConfig

useApproximateTopN - from a PlannerConfig

Returns:

query or null

toGroupByQuery

public GroupByQuery toGroupByQuery(DataSource dataSource,
                                   RowSignature sourceRowSignature,
                                   Map<String,Object> context)

Return this query as a GroupBy query, or null if this query is not compatible with GroupBy.

Parameters:

dataSource - data source to query

sourceRowSignature - row signature of the dataSource

context - query context

Returns:

query or null

toSelectQuery

public SelectQuery toSelectQuery(DataSource dataSource,
                                 RowSignature sourceRowSignature,
                                 Map<String,Object> context)

Return this query as a Select query, or null if this query is not compatible with Select.

Parameters:

dataSource - data source to query

sourceRowSignature - row signature of the dataSource

context - query context

Returns:

query or null

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