Guest User

Pig over cassandra script

a guest
Jun 17th, 2013
68
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.29 KB | None | 0 0
  1. data = LOAD 'cassandra://k1/t1' USING CassandraStorage();
  2. rows = FOREACH data GENERATE filtre.value as filtre, value_1.value as value;
  3. filtre_on_2 = FILTER rows BY filtre==2;
  4. group_filtre = GROUP filtre_on_2 BY filtre;
  5. somme = FOREACH group_filtre GENERATE SUM(filtre_on_2.value);
  6. dump somme;
Advertisement
Add Comment
Please, Sign In to add comment