I feel that this "streaming" in the source file is not in the sense of using scripts to run map/reduce but rather "sliding window stream processing" (See http://www.cs.cornell.edu/~mirek/papers/sigmod2003.pdf)
Pi On Tue, Mar 18, 2008 at 7:57 AM, Olga Natkovich <[EMAIL PROTECTED]> wrote: > We are working on support for streaming in pig similar to hadoop > streaming. Not sure if that's what you are asking. See details in > http://wiki.apache.org/pig/PigStreamingFunctionalSpec. > > Olga > > > -----Original Message----- > > From: pi song [mailto:[EMAIL PROTECTED] > > Sent: Monday, March 17, 2008 1:54 PM > > To: [email protected] > > Subject: anyone working on stream processing? > > > > Dear everyone, > > > > I've just recognized this file "TimeWindowSpec.java" in Pig. > > Is anyone currently working on stream processing? > > > > Cheers, > > Pi > > >
