Sorry about the post above this post, this is a complete one: Thanks joey, This look like the answer for me, but for the example in the link you give : A = load 'T';
B = group A by si
C = foreach B {
C1 = order A by d;
generate flatten(Stitch(C1, Over(C1.f, 'sum(float)')));
}
D = foreach C generate s, $9; I don't quite understand: i can't use GROUP BY and ORDER in this telematic data. So i try to run some exsample myselft: I just want to DUMP row x and another row with value is above x 1 line: EX: X: 2, 1, 3, 4 ... ,5 , 6. X': 0, 2, 1, 3, ...., 5 . B = LOAD '/user/hue/pig/drivers/drivers/1002/1.csv' using PigStorage(',') AS (x: float, y: float); C = FOREACH B GENERATE x , Over(x, lead, -1, 0, 1, 0); DUMP C; and got this error: <file script.pig, line 16, column 13> Failed to generate logical plan. Nested exception: org.apache.pig.backend.executionengine.ExecException: ERROR 1070: Could not resolve Over using imports: [, java.lang., org.apache.pig.builtin., org.apache.pig.impl.builtin.] I've already try this: B = LOAD '/user/hue/pig/drivers/drivers/1002/1.csv' using PigStorage(',') AS (x: float, y: float); C = FOREACH B GENERATE x , Over(B.x, lead, -1, 0, 1, 0); DUMP C; But still got the same error. Can you give me some more specific advise. Thanks !
... View more
