Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- q = load "dataset";
- q = group q by ('name', 'date_Year', 'date_Month', 'date_Day');
- q = foreach q generate 'name' as 'name', 'date_Year' + "~~~" + 'date_Month' + "~~~" + 'date_Day' as 'date_Year~~~date_Month~~~date_Day', sum('numberOfEvents') as 'sum_numberOfEvents';
- q = order q by ('name' asc, 'date_Year~~~date_Month~~~date_Day' asc);
- q = limit q 10000;
- q = load "dataset";
- q_A = filter q by date('date_Year', 'date_Month', 'date_Day') in ["1 day ago".."1 day ago"];
- q_B = filter q by date('date_Year', 'date_Month', 'date_Day') in ["current day".."current day"];
- result = group q_A by 'name' full, q_B by 'name';
- result = foreach result generate coalesce(q_A.'name', q_B.'name') as 'name', sum(q_A.'numberOfEvents') as 'A', sum(q_B.'numberOfEvents') as 'B';
- result = foreach result generate 'name', 'A', 'B', B-A as 'C';
- result = order result by ('C' desc);
- result = limit result 2000;
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement