Advertisement
Guest User

Untitled

a guest
Jun 19th, 2019
69
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.89 KB | None | 0 0
  1. q = load "dataset";
  2. q = group q by ('name', 'date_Year', 'date_Month', 'date_Day');
  3. 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';
  4. q = order q by ('name' asc, 'date_Year~~~date_Month~~~date_Day' asc);
  5. q = limit q 10000;
  6.  
  7. q = load "dataset";
  8. q_A = filter q by date('date_Year', 'date_Month', 'date_Day') in ["1 day ago".."1 day ago"];
  9. q_B = filter q by date('date_Year', 'date_Month', 'date_Day') in ["current day".."current day"];
  10. result = group q_A by 'name' full, q_B by 'name';
  11. 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';
  12. result = foreach result generate 'name', 'A', 'B', B-A as 'C';
  13. result = order result by ('C' desc);
  14. result = limit result 2000;
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement