pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From o...@apache.org
Subject svn commit: r775259 - /hadoop/pig/trunk/src/org/apache/pig/PigServer.java
Date Fri, 15 May 2009 17:51:12 GMT
Author: olga
Date: Fri May 15 17:51:12 2009
New Revision: 775259

URL: http://svn.apache.org/viewvc?rev=775259&view=rev
Log:
trivial change - added log message (hagleitn via olgan)

Modified:
    hadoop/pig/trunk/src/org/apache/pig/PigServer.java

Modified: hadoop/pig/trunk/src/org/apache/pig/PigServer.java
URL: http://svn.apache.org/viewvc/hadoop/pig/trunk/src/org/apache/pig/PigServer.java?rev=775259&r1=775258&r2=775259&view=diff
==============================================================================
--- hadoop/pig/trunk/src/org/apache/pig/PigServer.java (original)
+++ hadoop/pig/trunk/src/org/apache/pig/PigServer.java Fri May 15 17:51:12 2009
@@ -1083,12 +1083,14 @@
                         LoadFunc lFunc = (LoadFunc) pigContext.instantiateFuncFromSpec(load.getInputFile().getFuncSpec());
                         StoreFunc sFunc = (StoreFunc) pigContext.instantiateFuncFromSpec(store.getOutputFile().getFuncSpec());
                         if (lFunc.getClass() == sFunc.getClass() && lFunc instanceof
ReversibleLoadStoreFunc) {
-                        
-                        // In this case we remember the input file
-                        // spec in the store. We might have to use it
-                        // in the MR compiler to recreate the load, if
-                        // the store happens on a job boundary.
-                        store.setInputSpec(load.getInputFile());
+                            
+                            log.info("Removing unnecessary load operation from location:
"+ifile);
+                            
+                            // In this case we remember the input file
+                            // spec in the store. We might have to use it
+                            // in the MR compiler to recreate the load, if
+                            // the store happens on a job boundary.
+                            store.setInputSpec(load.getInputFile());
 
                             LogicalOperator storePred = lp.getPredecessors(store).get(0);
                             



Mime
View raw message