org.infinispan.distexec.mapreduce

Interface Mapper<KIn,VIn,KOut,VOut>

All Superinterfaces:

Serializable

All Known Implementing Classes:

IndexingMapper, WordCountMapper, WordCountMapperEmitPerValue

public interface Mapper<KIn,VIn,KOut,VOut>
extends Serializable

Implementation of a Mapper class is a component of a MapReduceTask invoked once for each input entry K,V. Every Mapper instance migrated to an Infinispan node, given a cache entry K,V input pair transforms that input pair into intermediate keys and emits them into Collector provided by Infinispan execution environment. Intermediate results are further reduced using a Reducer.

Since:

5.0

Author:

Manik Surtani, Vladimir Blagojevic, Sanne Grinovero

See Also:

Reducer, MapReduceTask

Method Summary

Methods

Modifier and Type	Method and Description
void	map(KIn key, VIn value, Collector<KOut,VOut> collector) Invoked once for each input cache entry KIn,VOut pair.

Method Detail

map

void map(KIn key,
       VIn value,
       Collector<KOut,VOut> collector)

Invoked once for each input cache entry KIn,VOut pair.