Author: daijy Date: Tue Dec 8 22:43:53 2009 New Revision: 888611 URL: http://svn.apache.org/viewvc?rev=888611&view=rev Log: PIG-1133: UDFContext should be made available to LoadFunc.bindTo
Modified: hadoop/pig/branches/branch-0.6/CHANGES.txt hadoop/pig/branches/branch-0.6/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/SliceWrapper.java Modified: hadoop/pig/branches/branch-0.6/CHANGES.txt URL: http://svn.apache.org/viewvc/hadoop/pig/branches/branch-0.6/CHANGES.txt?rev=888611&r1=888610&r2=888611&view=diff ============================================================================== --- hadoop/pig/branches/branch-0.6/CHANGES.txt (original) +++ hadoop/pig/branches/branch-0.6/CHANGES.txt Tue Dec 8 22:43:53 2009 @@ -227,6 +227,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/branches/branch-0.6/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/SliceWrapper.java URL: http://svn.apache.org/viewvc/hadoop/pig/branches/branch-0.6/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/SliceWrapper.java?rev=888611&r1=888610&r2=888611&view=diff ============================================================================== --- hadoop/pig/branches/branch-0.6/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/SliceWrapper.java (original) +++ hadoop/pig/branches/branch-0.6/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/SliceWrapper.java Tue Dec 8 22:43:53 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));