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 ----
|
