This is a pig datatype issue. It took me a while to get used to the pig types. See http://pig.apache.org/docs/r0.10.0/basic.html#Schemas
The relation below consists of two tuples of three values each: two integers and a bytearray. You could read this as follows: x = load 'file' as (t1:tuple(v1:int, v2:int, s), t2:tuple(v1:int, v2:int, s)); Once read, you can flatten as necessary. y = foreach x generate FLATTEN(t1), FLATTEN(t2); --Dan On Tue, Oct 23, 2012 at 8:24 AM, jamal sasha <[email protected]> wrote: > Hi I have a file in format > {(1,123,score) ,(1,124,score)} > {(2,356,score),(2,678,score)} > etc > > I am guessing the person who was working on this forgot to flatten this in > last step? > How do I read and flatten this ? >
