◢ <實作十一> | <回課程大綱> ▲ | <實作十三> ◣

實作十二 Lab12

• 延續上一個實作，我們也可以參考 FsShell.java 的 test(String argv[], int i) 函數，來撰寫檢驗 HDFS 狀態的程式

   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