Goal of this tutorial is to learn Apache Pig concepts in a fast pace. So don\u2019t except lengthy posts. All posts will be short and sweet. Most posts will have (very short) \u201csee it in action\u201d video.<\/strong><\/p>\n We have been learning a lot of concepts in Apache Pig (look at the previous posts). In this post we will see how to group records using Apache Pig.<\/p>\n With all the concepts we have seen so far, why don’t we solve a meaningful problem. Our stocks dataset has day by day stocks information like opening, closing prices, high, low and volume for the day for several symbols across many years. Let’s calculate the average volume for all stocks symbol from year 2003.<\/p>\n Look up previous posts to know more about loading and projecting datasets.<\/p>\n Now the dataset is loaded and filtered let’s group the records by symbol. Grouping records is very simple, use the GROUP…BY operator as follows<\/p>\n Now the records are grouped by symbol we can do more meaningful operations on the grouped records. In order to project\u00a0grp_by_sym<\/span>\u00a0we need to know the structure of\u00a0\u00a0grp_by_sym<\/span>\u00a0. Use the DESCRIBE operator on\u00a0grp_by_sym<\/span><\/p>\n From the describe operation we can see that grp_by_sym has two columns group <\/span>\u00a0and\u00a0filter_by_yr<\/span>\u00a0. group <\/span>\u00a0represents the column used for grouping, in our case we have grouped the records by symbol <\/span>\u00a0column so group <\/span>\u00a0represents symbol. filter_by_year <\/span>\u00a0will have the list of records for a given symbol.<\/p>\n Our goal is to project the symbol and the average volume for the symbol. So the below FOREACH projection would achieve that with AVG function.<\/p>\nLoad & Filter Records from 2003<\/h2>\n
grunt> stocks = LOAD '\/user\/hirw\/input\/stocks' USING PigStorage(',') as (exchange:chararray, symbol:chararray, date:datetime, open:float, high:float, low:float, close:float,\u00a0volume:int, adj_close:float);\n\ngrunt> filter_by_yr = FILTER stocks by GetYear(date) == 2003;<\/pre>\nGrouping Records<\/h2>\n
grunt> grp_by_sym = GROUP filter_by_yr BY symbol;<\/pre>\n
Finding Average<\/h2>\n
grunt> DESCRIBE grp_by_sym;\ngrp_by_sym: {group: chararray,filter_by_yr: {(exchange: chararray,symbol: chararray,date: datetime,open: float,high: float,low: float,close: float,volume: int,adj_close: float)}}<\/pre>\ngrunt> avg_volume = FOREACH grp_by_sym GENERATE group, ROUND(AVG(filter_by_yr.volume)) as avgvolume;<\/pre>\n
<\/h2>\n
Display Result<\/h2>\n
grunt> DUMP avg_volume;<\/pre>\n
<\/h2>\n
See It In Action<\/h2>\n