aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/physical/base/AbstractJoinPop.java
diff options
context:
space:
mode:
authorBoaz Ben-Zvi <boaz@mapr.com>2018-11-13 12:58:31 -0800
committerGitHub <noreply@github.com>2018-11-13 12:58:31 -0800
commit6267185823c4c50ab31c029ee5b4d9df2fc94d03 (patch)
tree3539d736acb0920e675c4f190dc58bb7271e7bdd /exec/java-exec/src/main/java/org/apache/drill/exec/physical/base/AbstractJoinPop.java
parent7079b8cd8e2f7ee07dac2fca4f2459af17eb8d6d (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.java7
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() {