Changeset 29 for sample


Ignore:
Timestamp:
Jul 3, 2008, 5:56:23 PM (16 years ago)
Author:
waue
Message:

..

File:
1 edited

Legend:

Unmodified
Added
Removed
  • sample/hadoop-0.16/tw/org/nchc/demo/LogFetcher.java

    r27 r29  
    4747import org.apache.hadoop.mapred.OutputCollector;
    4848import org.apache.hadoop.mapred.Reporter;
    49 
     49// import AccessLogParser
    5050/**
    5151 * Access_log fetcher. TODO: FgnStatLog, Error_log, Access_log (Default,
     
    7575        throws IOException {
    7676      try {
     77       
    7778        AccessLogParser log = new AccessLogParser(value.toString());
    7879        if (table == null)
     
    121122    jobConf.setJobName("apache log fetcher");
    122123    jobConf.set(TABLE, table);
    123 //     Path[] in = FileSystem.listPaths(fs, InputDir);
    124124    Path[] in = listPaths(fs, InputDir);
    125125    if (fs.isFile(InputDir)) {
     
    130130          jobConf.addInputPath(in[i]);
    131131        } else {
    132 //          Path[] sub = FileSystem.listPaths(fs, in[i]);
    133132          Path[] sub = listPaths(fs, in[i]);
    134133          for (int j = 0; j < sub.length; j++) {
     
    171170  }
    172171
    173   @SuppressWarnings("deprecation")
    174172  public static void main(String[] args) throws IOException {
    175173    String table_name = "log";
Note: See TracChangeset for help on using the changeset viewer.