Changes between Initial Version and Version 1 of III140118/Lab10

Timestamp:

Jan 18, 2014, 12:23:01 AM (12 years ago)

Author:

jazz

Comment:

--

III140118/Lab10

@@ +1 @@
+◢ <[wiki:III140118/Lab9 實作九]> | <[wiki:III140118 回課程大綱]> ▲ | <[wiki:III140118/Lab11 實作十一]> ◣
+
+= 實作十 Lab10 =
+
+{{{
+#!html
+<p style="text-align: center;"><big style="font-weight: bold;"><big>Hadoop FileSystem API 實作(一) <br/>Local 檔案上傳到 HDFS<br/>Upload Local Files and Directories to HDFS</big></big></p>
+}}}
+[[PageOutline]]
+{{{
+#!text
+請先連線至 nodeN.3du.me , N 為您的報名編號
+}}}
+
+ * 在上一個實作中，我們可以觀察 !FsShell.java 是如何使用 Path、Configration、!FileSystem 這幾個類別。
+ * 我們從模仿 hadoop fs -put 對應的函數 copyFromLocal(Path[] srcs, String dstf) 可以重新撰寫一個 Java Application 來學習 Hadoop !FileSystem API
+{{{
+#!java
+ 121   /**
+ 122    * Add local files to the indicated FileSystem name. src is kept.
+ 123    */
+ 124   void copyFromLocal(Path[] srcs, String dstf) throws IOException {
+ 125     Path dstPath = new Path(dstf);
+ 126     FileSystem dstFs = dstPath.getFileSystem(getConf());
+ 127     if (srcs.length == 1 && srcs[0].toString().equals("-"))
+ 128       copyFromStdin(dstPath, dstFs);
+ 129     else
+ 130       dstFs.copyFromLocalFile(false, false, srcs, dstPath);
+ 131   }
+}}}
+ * 讓我們先來觀察程式運作的情形，請剪貼以下步驟，並嘗試思考觀察到的現象(特別是 hadoop fs -ls 列出的結果差異)：
+{{{
+cd ~/hadoop_labs/lab004
+ant
+hadoop fs -ls
+hadoop fs -rmr input
+hadoop jar copyFromLocal.jar doc input
+hadoop fs -ls
+touch test
+hadoop jar copyFromLocal.jar test file
+hadoop fs -ls
+
+export HADOOP_CONF_DIR=~/hadoop/conf.local/
+hadoop fs -ls
+hadoop jar copyFromLocal.jar doc input
+hadoop fs -ls
+hadoop jar copyFromLocal.jar test file
+hadoop fs -ls
+unset HADOOP_CONF_DIR
+
+ant clean
+}}}