Support Questions

Find answers, ask questions, and share your expertise

How to flatten pig bags ?

Explorer

somedata = COGROUP clientdata BY clienid, enrolldata BY clientid, claims BY clientid

FOREACH somedata GENERATE flatten(clientdata , enrolldata , claims) as ( all meembers inside clientdata, enrolldata , claims) // at once so that we can send to hbase to one rowkey with multiple column familes.

1 REPLY 1

Hey @Veerendra Nath Jasthi!
I'm not an expert with PIG, but you can take a look at this (using datafu).
http://datafu.apache.org/docs/datafu/guide/more-tips-and-tricks.html

Hope this helps! 🙂