svn commit: r888600 - in /hadoop/pig/trunk: CHANGES.txt src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/SliceWrapper.java

[daijy]

Author: daijy
Date: Tue Dec  8 22:22:39 2009
New Revision: 888600

URL: http://svn.apache.org/viewvc?rev=888600&view=rev
Log:
PIG-1133: UDFContext should be made available to LoadFunc.bindTo

Modified:
    hadoop/pig/trunk/CHANGES.txt
    
hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/SliceWrapper.java

Modified: hadoop/pig/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/hadoop/pig/trunk/CHANGES.txt?rev=888600&r1=888599&r2=888600&view=diff
==============================================================================
--- hadoop/pig/trunk/CHANGES.txt (original)
+++ hadoop/pig/trunk/CHANGES.txt Tue Dec  8 22:22:39 2009
@@ -259,6 +259,8 @@
 PIG-1127: Logical operator should contains individual copy of schema object
 (daijy)
 
+PIG-1133: UDFContext should be made available to LoadFunc.bindTo (daijy)
+
 Release 0.5.0
 
 INCOMPATIBLE CHANGES

Modified: 
hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/SliceWrapper.java
URL: 
http://svn.apache.org/viewvc/hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/SliceWrapper.java?rev=888600&r1=888599&r2=888600&view=diff
==============================================================================
--- 
hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/SliceWrapper.java
 (original)
+++ 
hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/SliceWrapper.java
 Tue Dec  8 22:22:39 2009
@@ -53,6 +53,7 @@
 import org.apache.pig.impl.PigContext;
 import org.apache.pig.impl.plan.OperatorKey;
 import org.apache.pig.impl.util.ObjectSerializer;
+import org.apache.pig.impl.util.UDFContext;
 
 /**
  * Wraps a {...@link Slice} in an {...@link InputSplit} so it's usable by 
hadoop.
@@ -133,6 +134,11 @@
             job.set("pig.loader.signature", inpSignatureLists.get(index));
         }
         
+        // Get the UDF specific context
+        UDFContext udfc = UDFContext.getUDFContext();
+        udfc.addJobConf(job);
+        udfc.deserialize();
+        
         wrapped.init(store);
         
         job.set("map.target.ops", ObjectSerializer.serialize(targetOps));