public class DruidQueryRel extends DruidRel<DruidQueryRel>
Modifier and Type | Method and Description |
---|---|
DruidQueryRel |
asBindable() |
DruidQueryRel |
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 DruidQueryRel |
fullScan(org.apache.calcite.rel.logical.LogicalTableScan scanRel,
org.apache.calcite.plan.RelOptTable table,
DruidTable druidTable,
QueryMaker queryMaker)
Create a DruidQueryRel representing a full scan.
|
List<String> |
getDatasourceNames()
Get a list of names of datasources read by this DruidRel
|
PartialDruidQuery |
getPartialDruidQuery() |
int |
getQueryCount()
Return the number of Druid queries this rel involves, including sub-queries.
|
org.apache.calcite.plan.RelOptTable |
getTable() |
Sequence<Object[]> |
runQuery() |
DruidQuery |
toDruidQuery()
Convert this DruidRel to a DruidQuery.
|
DruidQuery |
toDruidQueryForExplaining()
Convert this DruidRel to a DruidQuery for purposes of explaining.
|
DruidQueryRel |
withPartialQuery(PartialDruidQuery newQueryBuilder) |
bind, getElementType, getPlannerContext, getQueryMaker, implement, isValidDruidQuery
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, getTraitSet, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, replaceInput, sole, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, copy, estimateRowCount, explain, getChildExps, getCollationList, getConvention, getCorrelVariable, getExpectedInputRowType, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, replaceInput
public static DruidQueryRel fullScan(org.apache.calcite.rel.logical.LogicalTableScan scanRel, org.apache.calcite.plan.RelOptTable table, DruidTable druidTable, QueryMaker queryMaker)
@Nonnull public DruidQuery toDruidQuery()
DruidRel
toDruidQuery
in class DruidRel<DruidQueryRel>
public DruidQuery toDruidQueryForExplaining()
DruidRel
toDruidQueryForExplaining
in class DruidRel<DruidQueryRel>
public DruidQueryRel asBindable()
asBindable
in class DruidRel<DruidQueryRel>
public DruidQueryRel asDruidConvention()
asDruidConvention
in class DruidRel<DruidQueryRel>
public List<String> getDatasourceNames()
DruidRel
getDatasourceNames
in class DruidRel<DruidQueryRel>
public PartialDruidQuery getPartialDruidQuery()
getPartialDruidQuery
in class DruidRel<DruidQueryRel>
public DruidQueryRel withPartialQuery(PartialDruidQuery newQueryBuilder)
withPartialQuery
in class DruidRel<DruidQueryRel>
public int getQueryCount()
DruidRel
getQueryCount
in class DruidRel<DruidQueryRel>
public Sequence<Object[]> runQuery()
runQuery
in class DruidRel<DruidQueryRel>
public org.apache.calcite.plan.RelOptTable getTable()
getTable
in interface org.apache.calcite.rel.RelNode
getTable
in class org.apache.calcite.rel.AbstractRelNode
protected org.apache.calcite.rel.type.RelDataType deriveRowType()
deriveRowType
in class org.apache.calcite.rel.AbstractRelNode
public org.apache.calcite.rel.RelWriter explainTerms(org.apache.calcite.rel.RelWriter pw)
explainTerms
in class org.apache.calcite.rel.AbstractRelNode
public org.apache.calcite.plan.RelOptCost computeSelfCost(org.apache.calcite.plan.RelOptPlanner planner, org.apache.calcite.rel.metadata.RelMetadataQuery mq)
computeSelfCost
in interface org.apache.calcite.rel.RelNode
computeSelfCost
in class org.apache.calcite.rel.AbstractRelNode
Copyright © 2011–2018. All rights reserved.