Changeset 27 for sample/hadoop-0.16/tw/org/nchc/demo/LogFetcher.java

Timestamp:

Jul 3, 2008, 5:25:22 PM (16 years ago)

Author:

waue

Message:

test!

File:

• sample/hadoop-0.16/tw/org/nchc/demo/LogFetcher.java (modified) (4 diffs)

sample/hadoop-0.16/tw/org/nchc/demo/LogFetcher.java

@@ +1 @@
+/**
+ * Program: LogFetcher.java
+ * Editor: Waue Chen 
+ * From :  NCHC. Taiwn
+ * Last Update Date: 07/02/2008
+ */
 /**
  * Copyright 2007 The Apache Software Foundation
@@ -95 +101 @@
     }
   }
+//   do it to resolve warning : FileSystem.listPaths 
   static public Path[] listPaths(FileSystem fsm,Path path) throws IOException
   {
@@ -114 +121 @@
     jobConf.setJobName("apache log fetcher");
     jobConf.set(TABLE, table);
-    // my convert function from 0.16 to 0.17
+//     Path[] in = FileSystem.listPaths(fs, InputDir);
     Path[] in = listPaths(fs, InputDir);
     if (fs.isFile(InputDir)) {
@@ -123 +130 @@
           jobConf.addInputPath(in[i]);
         } else {
-          // my convert function from 0.16 to 0.17
+//          Path[] sub = FileSystem.listPaths(fs, in[i]);
           Path[] sub = listPaths(fs, in[i]);
           for (int j = 0; j < sub.length; j++) {