You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by da...@apache.org on 2010/04/15 22:56:55 UTC
svn commit: r934591 -
/hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MRCompiler.java
Author: daijy
Date: Thu Apr 15 20:56:55 2010
New Revision: 934591
URL: http://svn.apache.org/viewvc?rev=934591&view=rev
Log:
PIG-1363: Unnecessary loadFunc instantiations (pig-1363_1.patch)
Modified:
hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MRCompiler.java
Modified: hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MRCompiler.java
URL: http://svn.apache.org/viewvc/hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MRCompiler.java?rev=934591&r1=934590&r2=934591&view=diff
==============================================================================
--- hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MRCompiler.java (original)
+++ hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MRCompiler.java Thu Apr 15 20:56:55 2010
@@ -1374,7 +1374,8 @@ public class MRCompiler extends PhyPlanV
rightMROpr.requestedParallelism = 1; // we need exactly one reducer for indexing job.
// At this point, we must be operating on map plan of right input and it would contain nothing else other then a POLoad.
- POLoad rightLoader = (POLoad)rightMROpr.mapPlan.getRoots().get(0);
+ POLoad rightLoader = (POLoad)rightMROpr.mapPlan.getRoots().get(0);
+ joinOp.setSignature(rightLoader.getSignature());
LoadFunc rightLoadFunc = rightLoader.getLoadFunc();
if(IndexableLoadFunc.class.isAssignableFrom(rightLoadFunc.getClass())) {
joinOp.setRightLoaderFuncSpec(rightLoader.getLFile().getFuncSpec());