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

Constructor Summary

Constructors

Constructor and Description
WordCountMapper()

Method Summary

Methods

Modifier and Type	Method and Description
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>