1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45
| 1.1) 建立测试目录 mkdir /home/hadoop/test cd /home/hadoop/test 1.2) 编写测试程序 cd /home/hadoop/test WordCount.java 1.3) 编译WordCount.java cd /home/hadoop/test mkdir WordCount javac -cp /home/hadoop/hadoop-1.2.1/hadoop-core-1.2.1.jar -d ./WordCount ./WordCount.java jar -cvf wordcount.jar -C WordCount/ . 1.4) 建立(准备)输入文件 cd /home/hadoop/test echo "Hello World Bye World" > file01 echo "Hello Hadoop GoodBye Hadoop" > file02 1.5) 上传输入文件(file01 file02) cd /home/hadoop/test ../hadoop-1.2.1/bin/hadoop dfs -mkdir input ../hadoop-1.2.1/bin/hadoop dfs -put ./file0* input #将本地文件系统上的./file0*(file01, file02)拷贝到HDFS的根目录下,目录名为input。 1.6) 运行 wordcount.jar cd /home/hadoop/test ../hadoop-1.2.1/bin/hadoop jar wordcount.jar WordCount input output #执行测试任务,输出到output。 1.7)查看输出文件 cd /home/hadoop/test ../hadoop-1.2.1/bin/hadoop fs -ls output
查看结果: ../hadoop-1.2.1/bin/hadoop fs -cat output/* ../hadoop-1.2.1/bin/hadoop fs -cat output/part-00000 1.8)将结果从HDFS复制到本地再查看 ../hadoop-1.2.1/bin/hadoop fs -get output ./output 1.9) 备注: ../hadoop-1.2.1/bin/hadoop fs –help 可以了解各种 HDFS命令的使用。
|