You can use UDFContext to pass information from the frontend to the backend. That is, if you want the UDF to generate some sequence number during the parse/planning stage and pass that to itself for use during execution, you can do that.
You cannot pass information between invocations of a UDF once you are running in the job. MapReduce does not provide any method of execution between tasks beyond the data. Doing so would require synchronization and a number of other features MapReduce doesn't provide. Alan. On Feb 22, 2012, at 8:57 PM, Shibu Thomas wrote: > Hi, > > Is there any mechanism of retaining state between PIG UDF invocations? > > Thanks > > Shibu Thomas > MSCIS-IS > Office : +91 (40) 669 32660 > Mobile: +91 95811 51116 >
