Advertisement
Guest User

Untitled

a guest
Apr 24th, 2019
81
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.38 KB | None | 0 0
  1. values = load 'pressure-data.avro' using AvroStorage('{
  2. "namespace":"com.syncfusion.stats",
  3. "type": "record",
  4. "name":"PressureReading",
  5. "fields":[
  6. {"name": "name", "type":"string"},
  7. {"name": "value", "type":"double"},
  8. {"name": "date", "type":"long"}
  9. ]
  10. }');
  11. sortedValues = ORDER values by value DESC;
  12. top10Values = LIMIT sortedValues 10;
  13. STORE top10Values INTO 'output' USING PigStorage(',');
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement