diff options
author | Boaz Ben-Zvi <boaz@mapr.com> | 2018-11-13 12:58:31 -0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-11-13 12:58:31 -0800 |
commit | 6267185823c4c50ab31c029ee5b4d9df2fc94d03 (patch) | |
tree | 3539d736acb0920e675c4f190dc58bb7271e7bdd /exec/java-exec/src/main/java/org/apache/drill/exec/physical/base/AbstractJoinPop.java | |
parent | 7079b8cd8e2f7ee07dac2fca4f2459af17eb8d6d (diff) |
Drill 6735: Implement Semi-Join for the Hash-Join operator (#1522)
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/physical/base/AbstractJoinPop.java')
-rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/physical/base/AbstractJoinPop.java | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/base/AbstractJoinPop.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/base/AbstractJoinPop.java index a624f5c2b..628dde7f0 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/base/AbstractJoinPop.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/base/AbstractJoinPop.java @@ -33,16 +33,19 @@ public abstract class AbstractJoinPop extends AbstractBase { protected final JoinRelType joinType; + protected final boolean semiJoin; + protected final LogicalExpression condition; protected final List<JoinCondition> conditions; public AbstractJoinPop(PhysicalOperator leftOp, PhysicalOperator rightOp, - JoinRelType joinType, LogicalExpression joinCondition, + JoinRelType joinType, boolean semiJoin, LogicalExpression joinCondition, List<JoinCondition> joinConditions) { left = leftOp; right = rightOp; this.joinType = joinType; + this.semiJoin = semiJoin; condition = joinCondition; conditions = joinConditions; } @@ -69,6 +72,8 @@ public abstract class AbstractJoinPop extends AbstractBase { return joinType; } + public boolean isSemiJoin() { return semiJoin; } + public LogicalExpression getCondition() { return condition; } public List<JoinCondition> getConditions() { |