org.infinispan.demo.mapreduce
Class WordCountMapper
java.lang.Object
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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
WordCountMapper
public WordCountMapper()
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.