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
