svn commit: r983278 - in /nutch/trunk: CHANGES.txt src/java/org/apache/nutch/crawl/Injector.java

[mattmann]

Author: mattmann
Date: Sat Aug  7 18:20:05 2010
New Revision: 983278

URL: http://svn.apache.org/viewvc?rev=983278&view=rev
Log:
- fix for NUTCH-870 Injector should add the metadata before calling 
injectedScore

Modified:
    nutch/trunk/CHANGES.txt
    nutch/trunk/src/java/org/apache/nutch/crawl/Injector.java

Modified: nutch/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/nutch/trunk/CHANGES.txt?rev=983278&r1=983277&r2=983278&view=diff
==============================================================================
--- nutch/trunk/CHANGES.txt (original)
+++ nutch/trunk/CHANGES.txt Sat Aug  7 18:20:05 2010
@@ -2,6 +2,8 @@ Nutch Change Log
 
 Release 2.0 - Current Development
 
+* NUTCH-870 Injector should add the metadata before calling injectedScore 
(jnioche via mattmann)
+
 * NUTCH-869 Add parse-html back (jnioche)
 
 * NUTCH-871 MoreIndexingFilter missing date format (Max        Lynch via 
mattmann)

Modified: nutch/trunk/src/java/org/apache/nutch/crawl/Injector.java
URL: 
http://svn.apache.org/viewvc/nutch/trunk/src/java/org/apache/nutch/crawl/Injector.java?rev=983278&r1=983277&r2=983278&view=diff
==============================================================================
--- nutch/trunk/src/java/org/apache/nutch/crawl/Injector.java (original)
+++ nutch/trunk/src/java/org/apache/nutch/crawl/Injector.java Sat Aug  7 
18:20:05 2010
@@ -128,19 +128,6 @@ public class Injector extends Configured
         value.set(url);                           // collect it
         CrawlDatum datum = new CrawlDatum(CrawlDatum.STATUS_INJECTED, 
customInterval);
         datum.setFetchTime(curTime);
-        if (customScore != -1) datum.setScore(customScore);
-        else {
-          datum.setScore(scoreInjected);
-          try {
-            scfilters.injectedScore(value, datum);
-          } catch (ScoringFilterException e) {
-            if (LOG.isWarnEnabled()) {
-              LOG.warn("Cannot filter injected score for url " + url
-                  + ", using default (" + e.getMessage() + ")");
-            }
-            datum.setScore(scoreInjected);
-          }
-        }
         // now add the metadata
         Iterator<String> keysIter = metadata.keySet().iterator();
         while (keysIter.hasNext()){
@@ -148,6 +135,16 @@ public class Injector extends Configured
                String valuemd = metadata.get(keymd);
                datum.getMetaData().put(new Text(keymd), new Text(valuemd));
         }
+        if (customScore != -1) datum.setScore(customScore);
+        else datum.setScore(scoreInjected);
+        try {
+               scfilters.injectedScore(value, datum);
+        } catch (ScoringFilterException e) {
+               if (LOG.isWarnEnabled()) {
+                       LOG.warn("Cannot filter injected score for url " + url
+                                       + ", using default (" + e.getMessage() 
+ ")");
+               }
+        }
         output.collect(value, datum);
       }
     }