pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pradeep...@apache.org
Subject svn commit: r898901 - /hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigInputFormat.java
Date Wed, 13 Jan 2010 19:20:02 GMT
Author: pradeepkth
Date: Wed Jan 13 19:20:02 2010
New Revision: 898901

URL: http://svn.apache.org/viewvc?rev=898901&view=rev
Log:
minor fix to pass real InputSplit in createRecordReader call in PigInputFormat

Modified:
    hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigInputFormat.java

Modified: hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigInputFormat.java
URL: http://svn.apache.org/viewvc/hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigInputFormat.java?rev=898901&r1=898900&r2=898901&view=diff
==============================================================================
--- hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigInputFormat.java
(original)
+++ hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigInputFormat.java
Wed Jan 13 19:20:02 2010
@@ -95,7 +95,8 @@
         PigInputFormat.mergeSplitSpecificConf(loadFunc, pigSplit, conf);
         InputFormat inputFormat = loadFunc.getInputFormat();
         // now invoke the createRecordReader() with this "adjusted" conf
-        RecordReader reader = inputFormat.createRecordReader(split, context);
+        RecordReader reader = inputFormat.createRecordReader(
+                pigSplit.getWrappedSplit(), context);
         
         return new PigRecordReader(reader, loadFunc, conf);
     }



Mime
View raw message