public class HashJoinPOP extends AbstractJoinPop
Modifier and Type | Field and Description |
---|---|
static String |
OPERATOR_TYPE |
condition, conditions, joinType, left, right, semiJoin
INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName
Constructor and Description |
---|
HashJoinPOP(PhysicalOperator left,
PhysicalOperator right,
List<JoinCondition> conditions,
org.apache.calcite.rel.core.JoinRelType joinType) |
HashJoinPOP(PhysicalOperator left,
PhysicalOperator right,
List<JoinCondition> conditions,
org.apache.calcite.rel.core.JoinRelType joinType,
boolean semiJoin,
RuntimeFilterDef runtimeFilterDef,
boolean isRowKeyJoin,
int joinControl) |
HashJoinPOP(PhysicalOperator left,
PhysicalOperator right,
List<JoinCondition> conditions,
org.apache.calcite.rel.core.JoinRelType joinType,
RuntimeFilterDef runtimeFilterDef) |
HashJoinPOP(PhysicalOperator left,
PhysicalOperator right,
List<JoinCondition> conditions,
org.apache.calcite.rel.core.JoinRelType joinType,
RuntimeFilterDef runtimeFilterDef,
boolean isRowKeyJoin,
int joinControl) |
Modifier and Type | Method and Description |
---|---|
HashJoinPOP |
flipIfRight() |
int |
getJoinControl() |
PhysicalOperator |
getNewWithChildren(List<PhysicalOperator> children)
Regenerate with this node with a new set of children.
|
String |
getOperatorType() |
RuntimeFilterDef |
getRuntimeFilterDef() |
SubScan |
getSubScanForRowKeyJoin() |
boolean |
isBufferedOperator(QueryContext queryContext)
The Hash Aggregate operator supports spilling
|
boolean |
isRowKeyJoin() |
void |
setMaxAllocation(long maxAllocation)
Any operator that supports spilling should override this method
|
void |
setRuntimeFilterDef(RuntimeFilterDef runtimeFilterDef) |
void |
setSubScanForRowKeyJoin(SubScan subScan) |
accept, getCondition, getConditions, getJoinType, getLeft, getRight, isSemiJoin, iterator
accept, getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getSVMode, getUserName, isExecutable, setCost, setOperatorId
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
public static final String OPERATOR_TYPE
public HashJoinPOP(PhysicalOperator left, PhysicalOperator right, List<JoinCondition> conditions, org.apache.calcite.rel.core.JoinRelType joinType, boolean semiJoin, RuntimeFilterDef runtimeFilterDef, boolean isRowKeyJoin, int joinControl)
public HashJoinPOP(PhysicalOperator left, PhysicalOperator right, List<JoinCondition> conditions, org.apache.calcite.rel.core.JoinRelType joinType, RuntimeFilterDef runtimeFilterDef, boolean isRowKeyJoin, int joinControl)
public HashJoinPOP(PhysicalOperator left, PhysicalOperator right, List<JoinCondition> conditions, org.apache.calcite.rel.core.JoinRelType joinType)
public HashJoinPOP(PhysicalOperator left, PhysicalOperator right, List<JoinCondition> conditions, org.apache.calcite.rel.core.JoinRelType joinType, RuntimeFilterDef runtimeFilterDef)
public PhysicalOperator getNewWithChildren(List<PhysicalOperator> children)
PhysicalOperator
public boolean isRowKeyJoin()
public int getJoinControl()
public SubScan getSubScanForRowKeyJoin()
public void setSubScanForRowKeyJoin(SubScan subScan)
public HashJoinPOP flipIfRight()
public String getOperatorType()
public void setMaxAllocation(long maxAllocation)
AbstractBase
setMaxAllocation
in interface PhysicalOperator
setMaxAllocation
in class AbstractBase
maxAllocation
- The max memory allocation to be setpublic boolean isBufferedOperator(QueryContext queryContext)
isBufferedOperator
in interface PhysicalOperator
isBufferedOperator
in class AbstractBase
queryContext
- public void setRuntimeFilterDef(RuntimeFilterDef runtimeFilterDef)
public RuntimeFilterDef getRuntimeFilterDef()
Copyright © 1970 The Apache Software Foundation. All rights reserved.