| 175 | |
| 176 | == job == |
| 177 | * 用以跟Map Reduce 的作業程序溝通 |
| 178 | * 在測試此指令之前,請確認已經先執行過mapReduce的程序過 |
| 179 | * 可到JobTracker:50030網頁來看程序的Jobid |
| 180 | === -status === |
| 181 | * 查看工作狀態 |
| 182 | {{{ |
| 183 | $ bin/hadoop job -status job_200904021140_0001 |
| 184 | |
| 185 | }}} |
| 186 | === -kill === |
| 187 | * 終止正在執行的程序,其id為 job_200904021140_0001 |
| 188 | {{{ |
| 189 | $ bin/hadoop job -kill job_200904021140_0001 |
| 190 | }}} |
| 191 | |
| 192 | |
| 193 | = streaming = |
| 194 | * Hadoop streaming是Hadoop的一個工具, 它幫助用戶創建和運行一類特殊的map/reduce作業, 這些特殊的map/reduce作業是由一些可執行文件或腳本文件充當mapper或者reducer |
| 195 | * 最簡單的透過shell執行stream的map reduce: |
| 196 | {{{ |
| 197 | $ bin/hadoop jar hadoop-0.18.3-streaming.jar -input input -output stream-output1 -mapper /bin/cat -reducer /usr/bin/wc |
| 198 | }}} |
| 199 | * 輸出的結果為: (代表 行、字數、字元數) |
| 200 | {{{ |
| 201 | #!sh |
| 202 | 2910628 24507806 143451003 |
| 203 | }}} |