I think you are looking for- C = join FILTERED_A by key1, B by key1; C1 = filter C by <some condition>;
if key1 equality is not your join condition, you may have to go for a CROSS. Thanks, Aniket On Thu, Mar 1, 2012 at 4:26 AM, mete <efk...@gmail.com> wrote: > Hello folks, > > i am new to pig-latin and i am trying to implement a use case as poc. > > I have 2 files that i should correlate, similar to this: > > A (date,key1,key2) > B (startdate,enddate,key1,key3) > > so what i am trying to do is: > query for key2 > for all the matches > find key3 from B if the date range matches > > So this is what i have come up with so far: > > A = LOAD ...; > B = LOAD ...; > > FILTERED_A = FILTER A BY key2="my_value"; > XX = FOREACH FILTERED_A { > RESULT= FILTER B BY (.... some conditions .....) > DUMP RESULT; > }; > > But this just gives me the error in subject without pointers to any > line/char. I am using 0.8.1-cdh3u3. > Any ideas? > > > As a side question, i could not figure out howto provide multiple input > files for pigunit for a case like the above, > Is anyone familiar with pigunit? > > > > Thanks in advance > Mete > -- "...:::Aniket:::... Quetzalco@tl"