Product SiteDocumentation Site

6.3. Example Usage

public class Mapper
{
    public void map(String key, String value)
    {
        String words[] = key.split(" ");
        for (int i = 0; i < words.length; i++)
        {
            Wmr.emit(words[i], "1");
        }
    }
}
public class Reducer
{
    public void reduce(String key, WmrIterator values)
    {
        int sum = 0;
        for (String value : values)
        {
            sum += Integer.parseInt(value);
        }
        Wmr.emit(key, Integer.valueOf(sum).toString());
    }
}