svn commit: r934591 - /hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MRCompiler.java

[daijy]

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());