Changes between Initial Version and Version 1 of III140412/Lab12

Timestamp:

Apr 11, 2014, 11:26:12 PM (11 years ago)

Author:

jazz

Comment:

--

III140412/Lab12

@@ +1 @@
+◢ <[wiki:III140412/Lab11 實作十一]> | <[wiki:III140412 回課程大綱]> ▲ | <[wiki:III140412/Lab13 實作十三]> ◣
+
+= 實作十二 Lab12 =
+
+{{{
+#!html
+<p style="text-align: center;"><big style="font-weight: bold;"><big>Hadoop FileSystem API 實作(三)<br/>判斷檔案是否存在、屬性為何<br/>Testing HDFS Directories and Files</big></big></p>
+}}}
+[[PageOutline]]
+{{{
+#!text
+請先連線至 nodeN.3du.me , N 為您的報名編號
+}}}
+
+ * 延續上一個實作，我們也可以參考 !FsShell.java 的 test(String argv[], int i) 函數，來撰寫檢驗 HDFS 狀態的程式
+{{{
+#!java
+ 751   int test(String argv[], int i) throws IOException {
+ 752     if (!argv[i].startsWith("-") || argv[i].length() > 2)
+ 753       throw new IOException("Not a flag: " + argv[i]);
+ 754     char flag = argv[i].toCharArray()[1];
+ 755     Path f = new Path(argv[++i]);
+ 756     FileSystem srcFs = f.getFileSystem(getConf());
+ 757     switch(flag) {
+ 758       case 'e':
+ 759         return srcFs.exists(f) ? 0 : 1;
+ 760       case 'z':
+ 761         return srcFs.getFileStatus(f).getLen() == 0 ? 0 : 1;
+ 762       case 'd':
+ 763         return srcFs.getFileStatus(f).isDir() ? 0 : 1;
+ 764       default:
+ 765         throw new IOException("Unknown flag: " + flag);
+ 766     }
+ 767   }
+}}}
+ * 讓我們來執行觀察程式運作的情形，請剪貼以下步驟，並嘗試思考觀察到的結果：
+{{{
+cd ~/hadoop_labs/lab006
+ant
+hadoop jar isFile.jar input
+hadoop jar isFile.jar file
+hadoop jar isFile.jar empty
+}}}
+
+ * 更多關於 HDFS !FileSystem API 的用法，請參考 org.apache.hadoop.fs.!FileSystem 的 javadoc
+  * http://hadoop.apache.org/docs/r1.0.4/api/org/apache/hadoop/fs/FileSystem.html