Method write

src/java/org/apache/nutch/crawl/InjectorJob.java:163–209

(String url, Context context, Integer customInterval,
        Float customScore, Map<String, String> metadata, InjectType injectType)

    }

    private void write(String url, Context context, Integer customInterval,
        Float customScore, Map<String, String> metadata, InjectType injectType)
            throws IOException, InterruptedException {
      try {
        url = urlNormalizers.normalize(url, URLNormalizers.SCOPE_INJECT);
        url = filters.filter(url); // filter the url
      } catch (Exception e) {
        LOG.warn("Skipping " + url + ":" + e);
        url = null;
      }
      if (url == null) {
        context.getCounter("injector", "urls_filtered").increment(1);
        return;
      } else { // if it passes
        String reversedUrl = TableUtil.reverseUrl(url); // collect it
        WebPage row = WebPage.newBuilder().build();
        row.setFetchTime(curTime);
        row.setFetchInterval(customInterval);

        // now add the metadata
        Iterator<String> keysIter = metadata.keySet().iterator();
        while (keysIter.hasNext()) {
          String keymd = keysIter.next();
          String valuemd = metadata.get(keymd);
          row.getMetadata().put(new Utf8(keymd),
              ByteBuffer.wrap(valuemd.getBytes(StandardCharsets.UTF_8)));
        }

        if (customScore != -1)
          row.setScore(customScore);
        else
          row.setScore(scoreInjected);

        try {
          scfilters.injectedScore(url, row);
        } catch (ScoringFilterException e) {
          if (LOG.isWarnEnabled()) {
            LOG.warn("Cannot filter injected score for url {}, using default ({})", url, e.getMessage());
          }
        }
        context.getCounter("injector", "urls_injected").increment(1);
        row.getMarkers()
        .put(DbUpdaterJob.DISTANCE, new Utf8(String.valueOf(0)));
        Mark.INJECT_MARK.putMark(row, injectType.getTypeString());
        context.write(reversedUrl, row);
      }
    }
  }

  public InjectorJob() {