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