Changes between Initial Version and Version 1 of waue/2010/0115-profile

Timestamp:

Jan 19, 2010, 7:20:33 PM (14 years ago)

Author:

waue

Comment:

--

waue/2010/0115-profile

@@ +1 @@
+
+ = 運算雛型 =
+
+{{{
+#!java
+import java.io.IOException;
+
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.fs.Path;
+import org.apache.hadoop.io.LongWritable;
+import org.apache.hadoop.io.Text;
+import org.apache.hadoop.mapreduce.Job;
+import org.apache.hadoop.mapreduce.Mapper;
+import org.apache.hadoop.mapreduce.Reducer;
+import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
+import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;
+
+//      HelloHadoop
+//      說明： 
+//              hadoop的hello world程式
+//              此程式可用來瞭解 hadoop的 <key , value> 為何值，並且練習hadoop api coding
+//
+//      測試方法：
+//      將此程式運作在hadoop 0.20 平台上，執行：
+//      ---------------------------
+//      hadoop jar HelloHadoop.jar
+//      ---------------------------
+//
+//      注意：
+//      1.      在hdfs 上來源檔案的路徑為 "/user/$YOUR_NAME/input"
+//              請注意必須先放資料到此hdfs上的資料夾內，且此資料夾內只能放檔案，不可再放資料夾
+//              input資料內的檔案若個數超過1個，則運算結果將會以某一個為主
+//      2.      運算完後，程式將執行結果放在hdfs 的輸出路徑為 "/user/$YOUR_NAME/output-hh1"
+//              請注意此資料夾為運算之後才產生的，故運算之前不可有此資料夾
+
+public class HelloHadoop {
+
+        static public class HelloMapper extends
+                        Mapper<LongWritable, Text, LongWritable, Text> {
+
+                public void map(LongWritable key, Text value, Context context)
+                                throws IOException, InterruptedException {
+                        // 將出入資料 原封不動的寫入 輸出
+                        context.write((LongWritable) key, (Text) value);
+                }
+
+        }
+
+        static public class HelloReducer extends
+                        Reducer<LongWritable, Text, LongWritable, Text> {
+                public void reduce(LongWritable key, Iterable<Text> values,
+                                Context context) throws IOException, InterruptedException {
+                        Text val = new Text();
+                        // 取回 val 的資料
+                        for (Text str : values) {
+                                val.set(str.toString());
+                        }
+                        // 將取回的資料引入輸出
+                        context.write(key, val);
+                }
+        }
+
+        public static void main(String[] args) throws IOException,
+                        InterruptedException, ClassNotFoundException {
+                // 引入 $HADOOP_HOME/conf 內控制檔內的資料
+                Configuration conf = new Configuration();
+                // 宣告job 取得conf 並設定名稱 Hadoop Hello World
+                Job job = new Job(conf, "Hadoop Hello World");
+                // 設定此運算的主程式
+                job.setJarByClass(HelloHadoop.class);
+                // 設定輸入路徑
+                FileInputFormat.setInputPaths(job, "input");
+                // 設定輸出路徑
+                FileOutputFormat.setOutputPath(job, new Path("output-hh1"));
+                // 指定定map class
+                job.setMapperClass(HelloMapper.class);
+                // 指定reduce class
+                job.setReducerClass(HelloReducer.class);
+                // 開使運算
+                job.waitForCompletion(true);
+
+        }
+}
+}}}