的 输入: 强>
2012-07-21T14:00:00.000Z,joe,hxxp:///www.aaa.com/home 2012-07-21T14:01:00.000Z,mary,hxxp:///www.aaa.com/watch 2012-07-21T14:02:00.000Z,joe,hxxp:///www.aaa.com/movie 2012-07-21T14:01:00.000Z,mary,hxxp:///www.aaa.com/mobile
的 猪脚本: 强>
user_navigation_data = LOAD 'user_nav_data.csv' USING PigStorage(',') AS (time:datetime,user:chararray,url:chararray); nav_data_grp_user = GROUP user_navigation_data BY user; user_nav_stats = FOREACH nav_data_grp_user { user_navigation_data_ord = ORDER user_navigation_data BY time; GENERATE group AS user, BagToString(user_navigation_data_ord.url,'-->') AS urls_accessed; };
的 输出:DUMP user_nav_stats: 强>
(joe,hxxp:///www.aaa.com/home-->hxxp:///www.aaa.com/movie) (mary,hxxp:///www.aaa.com/watch-->hxxp:///www.aaa.com/mobile)