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