public class DruidSemiJoin extends DruidRel<DruidSemiJoin>
Modifier and Type | Method and Description |
---|---|
DruidSemiJoin |
asBindable() |
DruidSemiJoin |
asDruidConvention() |
org.apache.calcite.plan.RelOptCost |
computeSelfCost(org.apache.calcite.plan.RelOptPlanner planner,
org.apache.calcite.rel.metadata.RelMetadataQuery mq) |
org.apache.calcite.rel.RelNode |
copy(org.apache.calcite.plan.RelTraitSet traitSet,
List<org.apache.calcite.rel.RelNode> inputs) |
static DruidSemiJoin |
create(DruidRel left,
DruidRel right,
List<Integer> leftKeys,
List<Integer> rightKeys,
PlannerContext plannerContext) |
protected org.apache.calcite.rel.type.RelDataType |
deriveRowType() |
org.apache.calcite.rel.RelWriter |
explainTerms(org.apache.calcite.rel.RelWriter pw) |
List<String> |
getDatasourceNames()
Get a list of names of datasources read by this DruidRel
|
List<org.apache.calcite.rel.RelNode> |
getInputs() |
PartialDruidQuery |
getPartialDruidQuery() |
int |
getQueryCount()
Return the number of Druid queries this rel involves, including sub-queries.
|
void |
replaceInput(int ordinalInParent,
org.apache.calcite.rel.RelNode p) |
Sequence<Object[]> |
runQuery() |
DruidQuery |
toDruidQuery()
Convert this DruidRel to a DruidQuery.
|
DruidQuery |
toDruidQueryForExplaining()
Convert this DruidRel to a DruidQuery for purposes of explaining.
|
DruidSemiJoin |
withPartialQuery(PartialDruidQuery newQueryBuilder) |
bind, getElementType, getPlannerContext, getQueryMaker, implement, isValidDruidQuery
accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeDigest, computeSelfCost, estimateRowCount, explain, getChildExps, getCluster, getCollationList, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getQuery, getRelTypeName, getRows, getRowType, getTable, getTraitSet, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, sole, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, estimateRowCount, explain, getChildExps, getCollationList, getConvention, getCorrelVariable, getExpectedInputRowType, getInput, getQuery, getRelTypeName, getRows, getRowType, getTable, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register
public static DruidSemiJoin create(DruidRel left, DruidRel right, List<Integer> leftKeys, List<Integer> rightKeys, PlannerContext plannerContext)
public PartialDruidQuery getPartialDruidQuery()
getPartialDruidQuery
in class DruidRel<DruidSemiJoin>
public DruidSemiJoin withPartialQuery(PartialDruidQuery newQueryBuilder)
withPartialQuery
in class DruidRel<DruidSemiJoin>
@Nullable public DruidQuery toDruidQuery()
DruidRel
toDruidQuery
in class DruidRel<DruidSemiJoin>
public DruidQuery toDruidQueryForExplaining()
DruidRel
toDruidQueryForExplaining
in class DruidRel<DruidSemiJoin>
public DruidSemiJoin asBindable()
asBindable
in class DruidRel<DruidSemiJoin>
public DruidSemiJoin asDruidConvention()
asDruidConvention
in class DruidRel<DruidSemiJoin>
public List<String> getDatasourceNames()
DruidRel
getDatasourceNames
in class DruidRel<DruidSemiJoin>
public int getQueryCount()
DruidRel
getQueryCount
in class DruidRel<DruidSemiJoin>
public Sequence<Object[]> runQuery()
runQuery
in class DruidRel<DruidSemiJoin>
protected org.apache.calcite.rel.type.RelDataType deriveRowType()
deriveRowType
in class org.apache.calcite.rel.AbstractRelNode
public List<org.apache.calcite.rel.RelNode> getInputs()
getInputs
in interface org.apache.calcite.plan.RelOptNode
getInputs
in interface org.apache.calcite.rel.RelNode
getInputs
in class org.apache.calcite.rel.AbstractRelNode
public void replaceInput(int ordinalInParent, org.apache.calcite.rel.RelNode p)
replaceInput
in interface org.apache.calcite.rel.RelNode
replaceInput
in class org.apache.calcite.rel.AbstractRelNode
public org.apache.calcite.rel.RelNode copy(org.apache.calcite.plan.RelTraitSet traitSet, List<org.apache.calcite.rel.RelNode> inputs)
copy
in interface org.apache.calcite.rel.RelNode
copy
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.