public class HiveJoin extends org.apache.calcite.rel.core.Join implements HiveRelNode
Modifier and Type | Class and Description |
---|---|
static class |
HiveJoin.MapJoinStreamingRelation |
HiveRelNode.Implementor
CONVENTION
Modifier | Constructor and Description |
---|---|
protected |
HiveJoin(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traits,
org.apache.calcite.rel.RelNode left,
org.apache.calcite.rel.RelNode right,
org.apache.calcite.rex.RexNode condition,
org.apache.calcite.rel.core.JoinRelType joinType,
Set<String> variablesStopped,
HiveCostModel.JoinAlgorithm joinAlgo) |
Modifier and Type | Method and Description |
---|---|
org.apache.calcite.rel.RelNode |
accept(org.apache.calcite.rel.RelShuttle shuttle) |
HiveJoin |
copy(org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.rex.RexNode conditionExpr,
org.apache.calcite.rel.RelNode left,
org.apache.calcite.rel.RelNode right,
org.apache.calcite.rel.core.JoinRelType joinType,
boolean semiJoinDone) |
org.apache.calcite.rel.RelWriter |
explainTerms(org.apache.calcite.rel.RelWriter pw) |
com.google.common.collect.ImmutableList<org.apache.calcite.rel.RelCollation> |
getCollation() |
Double |
getCumulativeMemoryWithinPhaseSplit() |
org.apache.calcite.rel.RelDistribution |
getDistribution() |
static HiveJoin |
getJoin(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.rel.RelNode left,
org.apache.calcite.rel.RelNode right,
org.apache.calcite.rex.RexNode condition,
org.apache.calcite.rel.core.JoinRelType joinType) |
HiveCostModel.JoinAlgorithm |
getJoinAlgorithm() |
org.apache.calcite.rex.RexNode |
getJoinFilter() |
HiveCalciteUtil.JoinPredicateInfo |
getJoinPredicateInfo() |
Double |
getMemory() |
org.apache.calcite.util.ImmutableBitSet |
getSortedInputs() |
Integer |
getSplitCount() |
org.apache.calcite.rel.RelNode |
getStreamingInput() |
HiveJoin.MapJoinStreamingRelation |
getStreamingSide() |
void |
implement(HiveRelNode.Implementor implementor) |
Boolean |
isPhaseTransition() |
void |
setJoinAlgorithm(HiveCostModel.JoinAlgorithm joinAlgorithm) |
void |
setJoinCost(org.apache.calcite.plan.RelOptCost joinCost) |
accept, analyzeCondition, computeSelfCost, copy, createJoinType, deriveJoinRowType, deriveRowType, estimateJoinedRows, estimateRowCount, getChildExps, getCondition, getJoinType, getSystemFieldList, getVariablesSet, isSemiJoinDone, isValid
childrenAccept, getInputs, getLeft, getRight, replaceInput
collectVariablesSet, collectVariablesUsed, computeDigest, computeSelfCost, explain, getCluster, getCollationList, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getQuery, getRelTypeName, getRows, getRowType, getTable, getTraitSet, getVariablesStopped, isDistinct, isKey, isValid, metadata, onRegister, recomputeDigest, register, sole, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, computeSelfCost, copy, estimateRowCount, explain, getChildExps, getCollationList, getConvention, getCorrelVariable, getExpectedInputRowType, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getTable, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, replaceInput
protected HiveJoin(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traits, org.apache.calcite.rel.RelNode left, org.apache.calcite.rel.RelNode right, org.apache.calcite.rex.RexNode condition, org.apache.calcite.rel.core.JoinRelType joinType, Set<String> variablesStopped, HiveCostModel.JoinAlgorithm joinAlgo) throws org.apache.calcite.rel.InvalidRelException, CalciteSemanticException
org.apache.calcite.rel.InvalidRelException
CalciteSemanticException
public static HiveJoin getJoin(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.rel.RelNode left, org.apache.calcite.rel.RelNode right, org.apache.calcite.rex.RexNode condition, org.apache.calcite.rel.core.JoinRelType joinType)
public void implement(HiveRelNode.Implementor implementor)
implement
in interface HiveRelNode
public final HiveJoin copy(org.apache.calcite.plan.RelTraitSet traitSet, org.apache.calcite.rex.RexNode conditionExpr, org.apache.calcite.rel.RelNode left, org.apache.calcite.rel.RelNode right, org.apache.calcite.rel.core.JoinRelType joinType, boolean semiJoinDone)
copy
in class org.apache.calcite.rel.core.Join
public org.apache.calcite.rex.RexNode getJoinFilter()
public HiveCalciteUtil.JoinPredicateInfo getJoinPredicateInfo()
public void setJoinAlgorithm(HiveCostModel.JoinAlgorithm joinAlgorithm)
public HiveCostModel.JoinAlgorithm getJoinAlgorithm()
public com.google.common.collect.ImmutableList<org.apache.calcite.rel.RelCollation> getCollation()
public org.apache.calcite.rel.RelDistribution getDistribution()
public Double getMemory()
public Double getCumulativeMemoryWithinPhaseSplit()
public Boolean isPhaseTransition()
public Integer getSplitCount()
public HiveJoin.MapJoinStreamingRelation getStreamingSide()
public org.apache.calcite.rel.RelNode getStreamingInput()
public org.apache.calcite.util.ImmutableBitSet getSortedInputs() throws CalciteSemanticException
CalciteSemanticException
public void setJoinCost(org.apache.calcite.plan.RelOptCost joinCost)
public org.apache.calcite.rel.RelWriter explainTerms(org.apache.calcite.rel.RelWriter pw)
explainTerms
in class org.apache.calcite.rel.core.Join
public org.apache.calcite.rel.RelNode accept(org.apache.calcite.rel.RelShuttle shuttle)
accept
in interface org.apache.calcite.rel.RelNode
accept
in class org.apache.calcite.rel.AbstractRelNode
Copyright © 2022 The Apache Software Foundation. All rights reserved.