Support Questions

Find answers, ask questions, and share your expertise

How to flatten pig bags ?


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.


Hey @Veerendra Nath Jasthi!
I'm not an expert with PIG, but you can take a look at this (using datafu).

Hope this helps! 🙂