Changes between Version 13 and Version 14 of LogParser

Timestamp:

Jul 7, 2008, 12:13:29 PM (16 years ago)

Author:

waue

Comment:

--

LogParser

@@ -39 +39 @@
         public static class MapClass extends MapReduceBase implements
                         Mapper<WritableComparable, Text, Text, Writable> {
-                @Override
-                // MapReduceBase.configure(JobConf job) 
-                // Default implementation that does nothing.
                 public void configure(JobConf job) {
-                        // String get(String name,String defaultValue) 
-                        // Get the value of the name property. If no such property exists,\
-                        //      then defaultValue is returned.
                         tableName = job.get(TABLE, "");
                 }
-
                 public void map(WritableComparable key, Text value,
                                 OutputCollector<Text, Writable> output, Reporter reporter)
                                 throws IOException {
-                        
                         try {
-                                /*
-                                print(value.toString());
-                                FileWriter out = new FileWriter(new File(
-                                "/home/waue/mr-result.txt"));
-                                out.write(value.toString());
-                                out.flush();
-                                out.close();
-                                */
                                 LogParser log = new LogParser(value.toString());
-                                
                                 if (table == null)
                                         table = new HTable(conf, new Text(tableName));
@@ -82 +65 @@
                                                 log.getUrl().getBytes());
                                 table.commit(lockId, log.getTimestamp());
-                                
                         } catch (Exception e) {
                                 e.printStackTrace();
                         }
-                        
                 }
         }