| | 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 | }}} |