You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mrql.apache.org by fe...@apache.org on 2014/08/03 16:32:23 UTC
git commit: MRQL-44: Fix the map-reduce join for a complex reducer on
map-reduce mode
Repository: incubator-mrql
Updated Branches:
refs/heads/master e5529da5a -> 5258de79a
MRQL-44: Fix the map-reduce join for a complex reducer on map-reduce mode
Project: http://git-wip-us.apache.org/repos/asf/incubator-mrql/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-mrql/commit/5258de79
Tree: http://git-wip-us.apache.org/repos/asf/incubator-mrql/tree/5258de79
Diff: http://git-wip-us.apache.org/repos/asf/incubator-mrql/diff/5258de79
Branch: refs/heads/master
Commit: 5258de79aa1f6f98787b9b4b037ceae5437e6a53
Parents: e5529da
Author: fegaras <fe...@cse.uta.edu>
Authored: Sun Aug 3 09:31:49 2014 -0500
Committer: fegaras <fe...@cse.uta.edu>
Committed: Sun Aug 3 09:31:49 2014 -0500
----------------------------------------------------------------------
mapreduce/src/main/java/org/apache/mrql/JoinOperation.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-mrql/blob/5258de79/mapreduce/src/main/java/org/apache/mrql/JoinOperation.java
----------------------------------------------------------------------
diff --git a/mapreduce/src/main/java/org/apache/mrql/JoinOperation.java b/mapreduce/src/main/java/org/apache/mrql/JoinOperation.java
index 0258c07..a59ffdc 100644
--- a/mapreduce/src/main/java/org/apache/mrql/JoinOperation.java
+++ b/mapreduce/src/main/java/org/apache/mrql/JoinOperation.java
@@ -289,7 +289,9 @@ final public class JoinOperation extends MapReducePlan {
};
pair.set(0,left);
pair.set(1,right);
- for ( MRData e: (Bag)reduce_fnc.eval(pair) ) {
+ Bag s = (Bag)reduce_fnc.eval(pair);
+ s.materialize();
+ for ( MRData e: s ) {
ckey.set(key.key);
write(ckey,e,context);
}