You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by ol...@apache.org on 2008/08/08 00:11:42 UTC

svn commit: r683736 - in /incubator/pig/branches/types: CHANGES.txt src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigInputFormat.java

Author: olga
Date: Thu Aug  7 15:11:41 2008
New Revision: 683736

URL: http://svn.apache.org/viewvc?rev=683736&view=rev
Log:
PIG-368: making JobConf available to the Load/Store UDFs

Modified:
    incubator/pig/branches/types/CHANGES.txt
    incubator/pig/branches/types/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigInputFormat.java

Modified: incubator/pig/branches/types/CHANGES.txt
URL: http://svn.apache.org/viewvc/incubator/pig/branches/types/CHANGES.txt?rev=683736&r1=683735&r2=683736&view=diff
==============================================================================
--- incubator/pig/branches/types/CHANGES.txt (original)
+++ incubator/pig/branches/types/CHANGES.txt Thu Aug  7 15:11:41 2008
@@ -147,3 +147,5 @@
     PIG-363: fix for describe to produce schema name
 
     PIG-367: convinience function for UDFs to name schema
+
+    PIG-368: making JobConf available to Load/Store UDFs

Modified: incubator/pig/branches/types/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigInputFormat.java
URL: http://svn.apache.org/viewvc/incubator/pig/branches/types/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigInputFormat.java?rev=683736&r1=683735&r2=683736&view=diff
==============================================================================
--- incubator/pig/branches/types/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigInputFormat.java (original)
+++ incubator/pig/branches/types/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigInputFormat.java Thu Aug  7 15:11:41 2008
@@ -268,7 +268,7 @@
 
         CompressionCodecFactory compressionFactory;
 
-        JobConf job;
+        public static JobConf job;
         
         /**
          * Uses the split to get information about the input
@@ -282,7 +282,7 @@
         PigRecordReader(JobConf job, PigSplit split,
                 CompressionCodecFactory compressionFactory) throws IOException {
             this.split = split;
-            this.job = job;
+            PigRecordReader.job = job;
             this.compressionFactory = compressionFactory;
             loader = split.getLoadFunction();
             Path path = split.getPath();