org.infinispan.demo.mapreduce

Class WordCountMapperEmitPerValue

java.lang.Object

org.infinispan.demo.mapreduce.WordCountMapperEmitPerValue

All Implemented Interfaces:

Serializable, Mapper<String,String,String,Integer>

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
WordCountMapperEmitPerValue()

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

WordCountMapperEmitPerValue

public WordCountMapperEmitPerValue()

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>