"Non-linear" data flow split with 1 leg

2012-03-13 Thread Charles Menguy
Hi all, I have a question about PIG regarding non-linear data flows. I'm using the SPLIT command to be able to do different behavior based on my data, but I noticed something unexpected. When I do a SPLIT with only 1 leg, for some reason that doesn't work, as it seems to be expecting at least a

Re: Pig counters with PigServer strange behavior

2011-12-12 Thread Charles Menguy
patch, which simply removes the declaration of this temporary counters variable. Counters now work with PigRunner and PigServer as well. Hope this information can prevent others from being stuck with this issue ! Thanks, Charles On Wed, Dec 7, 2011 at 10:04 AM, Charles Menguy < c

Re: Pig counters with PigServer strange behavior

2011-12-07 Thread Charles Menguy
kashi wrote: > There is a good blog article on this- > > http://squarecog.wordpress.com/2010/12/24/incrementing-hadoop-counters-in-apache-pig/ > > Thanks, > Aniket > > On Tue, Dec 6, 2011 at 1:49 PM, Charles Menguy < > cmen...@proclivitysystems.com> wrote: &

Pig counters with PigServer strange behavior

2011-12-06 Thread Charles Menguy
counters, or forgetting something? I'm using pig 0.8.1 from cdh3u1 Thanks for your help ! -- Charles Menguy | Senior Software Engineer Proclivity Systems 22 West 19th Street | 9th Floor New York, NY 10011 cmen...@proclivitysystems.com www.proclivitysystems.com Proclivity® | We Value Your Cus

Re: PigServer and dynamic invokers

2011-11-17 Thread Charles Menguy
senberg > wrote: > > Hi Dimitriy, > > > > The script does run if invoked from command line but only if we set > > PIG_CLASSPATH to point at the jar. > > > > stan > > On Nov 16, 2011 11:18 PM, "Dmitriy Ryaboy" wrote: > > > >> Do

PigServer and dynamic invokers

2011-11-16 Thread Charles Menguy
Hi, We're trying to run a PIG script using the PigServer API in Java, but we're having a couple issues. It seems to work well in most cases, but in our case we need to use Pig's dynamic invokers. Basically this looks something like the following: DEFINE isEmail InvokeForInt('com.company.pig.udf.U