Richard, Got it! Thanks for your quick reply.
- Youngwoo 2011년 1월 20일 오전 5:43, Richard Ding <[email protected]>님의 말: > Youngwoo, > > It will work if you change the foreach statement to > > r1 = FOREACH records GENERATE LOWER(input_line); > > Otherwise Pig thinks that your intent is to use relation (‘records’) as > scalar (this is a new feature of 0.8). > > Thanks, > - Richard > > > On 1/18/11 10:36 PM, "김영우" <[email protected]> wrote: > > Richard, > > I found my mistakes. Your example works well with 'normal' relations(bag). > but in my test code Pig did implicit casting from relations to scalars. > > r1 = FOREACH records GENERATE LOWER(records.input_line); > STORE r1 INTO '$out'; > > > > I need to store 'r1' as a bag. How can I do this? > > Thanks. > > - Youngwoo? > > 2011년 1월 19일 오전 3:55, Richard Ding <[email protected]>님의 말: > > The method you’re looking for is PigStats.result(String alias) which > returns a OutputStats object. > > Here is an example: > > R = Pig.compile(...).bind(...).runSingle() > iter = R.result(“G”).iterator() > while iter.hasNext(): > ????t = iter.next() > ????.... > > On 1/17/11 9:34 PM, "김영우" <[email protected] <http://[email protected]> > > wrote: > > Hi All, > > I'm looking into embedding pig latin in a host language using pig trunk. so > far, basic features work fine for me. but I need to know how can I get > result tuples from the stored bag. > I need to apply some processing to each tuple from result bag. In wiki > http://wiki.apache.org/pig/TuringCompletePig , It seems 'getResults()' > method works like what I want. but I got an error like "returned PigStats > has no attribute 'getResults()' ..." > > Any advice would be appreciated. > > - Youngwoo > > > >
