From: Doug C. <cu...@us...> - 2005-09-01 17:37:02
|
Update of /cvsroot/archive-access/archive-access/projects/nutch/src/java/org/archive/access/nutch In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv6304 Modified Files: Tag: mapred Arc2Segment.java Log Message: Use reporter to set status. Index: Arc2Segment.java =================================================================== RCS file: /cvsroot/archive-access/archive-access/projects/nutch/src/java/org/archive/access/nutch/Arc2Segment.java,v retrieving revision 1.28.2.7 retrieving revision 1.28.2.8 diff -C2 -d -r1.28.2.7 -r1.28.2.8 *** Arc2Segment.java 24 Aug 2005 04:15:48 -0000 1.28.2.7 --- Arc2Segment.java 1 Sep 2005 17:36:53 -0000 1.28.2.8 *************** *** 132,136 **** arcName = arcName.substring(0, arcName.indexOf(".arc")); } ! LOG.info("arcName="+arcName); } --- 132,136 ---- arcName = arcName.substring(0, arcName.indexOf(".arc")); } ! reporter.setStatus(arcName); } *************** *** 138,142 **** continue; try { ! processRecord(arcName, rec, output, reporter); } catch (Throwable e) { LOG.log(Level.WARNING, "Error processing: " + arcLocation, e); --- 138,142 ---- continue; try { ! processRecord(arcName, rec, output); } catch (Throwable e) { LOG.log(Level.WARNING, "Error processing: " + arcLocation, e); *************** *** 149,153 **** private void processRecord(final String arcName, final ARCRecord rec, ! OutputCollector output, Reporter reporter) throws IOException { --- 149,153 ---- private void processRecord(final String arcName, final ARCRecord rec, ! OutputCollector output) throws IOException { *************** *** 155,160 **** String url = arcData.getUrl(); - reporter.setStatus(url); - String mimetype = arcData.getMimetype(); if (mimetype != null && mimetype.length() > 0) { --- 155,158 ---- |