- Hadoop MapReduce v2 Cookbook(Second Edition)
- Thilina Gunarathne
- 224字
- 2021-07-23 20:32:53
Running the WordCount program in a distributed cluster environment
This recipe describes how to run a MapReduce computation in a distributed Hadoop v2 cluster.
Getting ready
Start the Hadoop cluster by following the Setting up HDFS recipe or the Setting up Hadoop ecosystem in a distributed cluster environment using a Hadoop distribution recipe.
How to do it...
Now let's run the WordCount sample in the distributed Hadoop v2 setup:
- Upload the
wc-input
directory in the source repository to the HDFS filesystem. Alternatively, you can upload any other set of text documents as well.$ hdfs dfs -copyFromLocal wc-input .
- Execute the WordCount example from the
HADOOP_HOME
directory:$ hadoop jar hcb-c1-samples.jar \ chapter1.WordCount \ wc-input wc-output
- Run the following commands to list the output directory and then look at the results:
$hdfs dfs -ls wc-output Found 3 items -rw-r--r-- 1 joesupergroup0 2013-11-09 09:04 /data/output1/_SUCCESS drwxr-xr-x - joesupergroup0 2013-11-09 09:04 /data/output1/_logs -rw-r--r-- 1 joesupergroup1306 2013-11-09 09:04 /data/output1/part-r-00000 $ hdfs dfs -cat wc-output/part*
How it works...
When we submit a job, YARN would schedule a MapReduce ApplicationMaster to coordinate and execute the computation. ApplicationMaster requests the necessary resources from the ResourceManager and executes the MapReduce computation using the containers it received from the resource request.
There's more...
You can also see the results of the WordCount application through the HDFS monitoring UI by visiting http://NAMANODE:50070
.
推薦閱讀
- Learning Python Web Penetration Testing
- Designing Machine Learning Systems with Python
- C語言程序設(shè)計教程
- 深入理解Bootstrap
- Learning Real-time Processing with Spark Streaming
- Vue.js 2 and Bootstrap 4 Web Development
- Interactive Data Visualization with Python
- Mastering Python Scripting for System Administrators
- 零基礎(chǔ)學(xué)Java(第4版)
- 人人都懂設(shè)計模式:從生活中領(lǐng)悟設(shè)計模式(Python實現(xiàn))
- Java EE 7 Performance Tuning and Optimization
- 51單片機C語言開發(fā)教程
- After Effects CC案例設(shè)計與經(jīng)典插件(視頻教學(xué)版)
- Java核心編程
- jQuery基礎(chǔ)教程(第4版)