org.infinispan.distexec.mapreduce
Interface Mapper<KIn,VIn,KOut,VOut>
- All Superinterfaces:
- Serializable
- All Known Implementing Classes:
- WordCountMapper
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 |
void |
map(KIn key,
VIn value,
Collector<KOut,VOut> collector)
Invoked once for each input cache entry KIn,VOut pair. |
map
void map(KIn key,
VIn value,
Collector<KOut,VOut> collector)
- Invoked once for each input cache entry KIn,VOut pair.
Copyright © 2011 JBoss, a division of Red Hat. All Rights Reserved.