[[PageOutline]]

◢ <[wiki:III120825/Lab10 實作十]> | <[wiki:III120825 回課程大綱]> ▲ | <[wiki:III120825/Lab12 實作十二]> ◣

= 實作十一 Lab 11 =

{{{
#!html
<div style="text-align: center;"><big style="font-weight: bold;"><big>練習豬的拉丁語<br/>Pig Latin in Practice</big></big></div>
}}}

{{{
#!text
以下練習，請連線至 hadoop.classcloud.org 操作。底下的 hXXXX 等於您的用戶名稱。
}}}

== Aggregation (Local Mode) ==

{{{
~$ cp /opt/pig/tutorial/data/excite-small.log .
~$ pig -x local
grunt> log = LOAD 'excite-small.log' AS (user, timestamp, query);
grunt> grpd = GROUP log BY user;
grunt> cntd = FOREACH grpd GENERATE group, COUNT(log);
grunt> STORE cntd INTO 'lab8_out1';
grunt> quit
~$ cat lab8_out1/part-r-00000
}}}

== Filter (Local Mode) ==

{{{
~$ pig -x local
grunt> log = LOAD 'excite-small.log' AS (user, timestamp, query);
grunt> grpd = GROUP log BY user;
grunt> cntd = FOREACH grpd GENERATE group, COUNT(log) AS cnt;
grunt> fltrd = FILTER cntd BY cnt > 50;
grunt> STORE fltrd INTO 'lab8_out2';
grunt> quit
~$ cat lab8_out2/part-r-00000
}}}

== Sorting (Local Mode) ==

{{{
~$ pig -x local
grunt> log = LOAD 'excite-small.log' AS (user, timestamp, query);
grunt> grpd = GROUP log BY user;
grunt> cntd = FOREACH grpd GENERATE group, COUNT(log) AS cnt;
grunt> fltrd = FILTER cntd BY cnt > 50;
grunt> srtd = ORDER fltrd BY cnt;
grunt> STORE srtd INTO 'lab8_out3';
grunt> quit
~$ cat lab8_out3/part-r-00000
}}}

== Connect Pig to Hadoop (Full Distributed Mode) ==

{{{
~$ hadoop fs -put excite-small.log .
~$ pig
grunt> log = LOAD 'excite-small.log' AS (user, timestamp, query);
grunt> grpd = GROUP log BY user;
grunt> cntd = FOREACH grpd GENERATE group, COUNT(log);
grunt> STORE cntd INTO 'lab8_out1';
grunt> quit
~$ hadoop fs -cat lab8_out1/part-00000
}}}