[
https://issues.apache.org/jira/browse/NUTCH-1225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Markus Jelsma updated NUTCH-1225:
---------------------------------
Attachment: NUTCH-1225-1.5-2.patch
New patch uses proper value iteration in reducer.
Old API:
{code}
public void reduce(Text key, Iterator<CrawlDatum> values, Context context)
throws IOException, InterruptedException {
while (values.hasNext()) {
CrawlDatum val = values.next();
context.write(key, val);
}
}
{code}
New API:
{code}
public void reduce(Text key, Iterable<CrawlDatum> values, Context context)
throws IOException, InterruptedException {
for (CrawlDatum val : values) {
context.write(key, val);
}
}
{code}
> Migrate CrawlDBScanner to MapReduce API
> ---------------------------------------
>
> Key: NUTCH-1225
> URL: https://issues.apache.org/jira/browse/NUTCH-1225
> Project: Nutch
> Issue Type: Sub-task
> Reporter: Markus Jelsma
> Assignee: Markus Jelsma
> Fix For: 1.5
>
> Attachments: NUTCH-1225-1.5-1.patch, NUTCH-1225-1.5-2.patch
>
>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
