org.infinispan.demo.mapreduce
Class WordCountMapper

java.lang.Object
  extended by org.infinispan.demo.mapreduce.WordCountMapper
All Implemented Interfaces:
Serializable, Mapper<String,String,String,Integer>

public class WordCountMapper
extends Object
implements Mapper<String,String,String,Integer>

See Also:
Serialized Form

Constructor Summary
WordCountMapper()
           
 
Method Summary
 void map(String key, String value, Collector<String,Integer> c)
          Invoked once for each input cache entry KIn,VOut pair.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

WordCountMapper

public WordCountMapper()
Method Detail

map

public void map(String key,
                String value,
                Collector<String,Integer> c)
Description copied from interface: Mapper
Invoked once for each input cache entry KIn,VOut pair.

Specified by:
map in interface Mapper<String,String,String,Integer>

-->

Copyright © 2011 JBoss, a division of Red Hat. All Rights Reserved.