| commit | 8d8d4771657038340631aa64a529ed4502175484 | [log] [tgz] |
|---|---|---|
| author | alexander.behm <alexander.behm@123451ca-8445-de46-9d55-352943316053> | Mon Jan 21 20:29:06 2013 +0000 |
| committer | alexander.behm <alexander.behm@123451ca-8445-de46-9d55-352943316053> | Mon Jan 21 20:29:06 2013 +0000 |
| tree | 3f33c71578a72aa580d5d69d7b033578b8e9c9b2 | |
| parent | c0ec868205878fc108a0e0aa442671886851aee8 [diff] |
Changed broadcast side of indexed nested loops join. git-svn-id: https://hyracks.googlecode.com/svn/branches/hyracks_lsm_experiments@2694 123451ca-8445-de46-9d55-352943316053
diff --git a/hyracks-algebricks/hyracks-algebricks-core/src/main/java/edu/uci/ics/hyracks/algebricks/core/algebra/operators/physical/NLJoinPOperator.java b/hyracks-algebricks/hyracks-algebricks-core/src/main/java/edu/uci/ics/hyracks/algebricks/core/algebra/operators/physical/NLJoinPOperator.java index 8cbd2d8..ec829db 100644 --- a/hyracks-algebricks/hyracks-algebricks-core/src/main/java/edu/uci/ics/hyracks/algebricks/core/algebra/operators/physical/NLJoinPOperator.java +++ b/hyracks-algebricks/hyracks-algebricks-core/src/main/java/edu/uci/ics/hyracks/algebricks/core/algebra/operators/physical/NLJoinPOperator.java
@@ -111,9 +111,10 @@ throw new NotImplementedException(partitioningType + " nested loop joins are not implemented."); } + // ALEX: HACK TO FLIP WHICH SIDE IS BROADCAST StructuralPropertiesVector[] pv = new StructuralPropertiesVector[2]; - pv[0] = new StructuralPropertiesVector(new BroadcastPartitioningProperty(null), null); - pv[1] = new StructuralPropertiesVector(null, null); + pv[1] = new StructuralPropertiesVector(new BroadcastPartitioningProperty(null), null); + pv[0] = new StructuralPropertiesVector(null, null); return new PhysicalRequirements(pv, IPartitioningRequirementsCoordinator.NO_COORDINATION); }