We really need an APPLY function (really, it's map, but don't want to overload the terms), which would take a funcspec and apply it to every element in a tuple or bag. Then you could say FOREACH x GENERATE APPLY REPLACE(*, "char", "\\char") TO (a, b, c);
That would be rad. Especially useful when dealing with the bags produced by grouping things and projections on such bags. -D On Wed, Jun 16, 2010 at 6:10 AM, jr <[email protected]>wrote: > Hello Everybody, > I'm looking for a way to run REPLACE on multiple columns in a dataset to > escape some characters that would confuse loading after processing in > pig. > Is there an easy way to do that without having to do > > FOREACH x GENERATE REPLACE(a,"char","\\char"), REPLACE(b,"char","\ > \char"), REPLACE(c... etc > > ? > Johannes > >
