Changeset 29

Timestamp:

Jul 3, 2008, 5:56:23 PM (16 years ago)

Author:

waue

Message:

..

File:

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

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

@@ -47 +47 @@
 import org.apache.hadoop.mapred.OutputCollector;
 import org.apache.hadoop.mapred.Reporter;
-
+// import AccessLogParser
 /**
  * Access_log fetcher. TODO: FgnStatLog, Error_log, Access_log (Default,
@@ -75 +75 @@
         throws IOException {
       try {
+        
         AccessLogParser log = new AccessLogParser(value.toString());
         if (table == null)
@@ -121 +122 @@
     jobConf.setJobName("apache log fetcher");
     jobConf.set(TABLE, table);
-//     Path[] in = FileSystem.listPaths(fs, InputDir);
     Path[] in = listPaths(fs, InputDir);
     if (fs.isFile(InputDir)) {
@@ -130 +130 @@
           jobConf.addInputPath(in[i]);
         } else {
-//          Path[] sub = FileSystem.listPaths(fs, in[i]);
           Path[] sub = listPaths(fs, in[i]);
           for (int j = 0; j < sub.length; j++) {
@@ -171 +170 @@
   }
 
-  @SuppressWarnings("deprecation")
   public static void main(String[] args) throws IOException {
     String table_name = "log";