org.infinispan.distexec.mapreduce
Interface Mapper<K,V,T>


public interface Mapper<K,V,T>

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 a result T. Intermediate result T is further reduced using a Reducer.

Since:
5.0
Author:
Manik Surtani, Vladimir Blagojevic
See Also:
Reducer, MapReduceTask

Method Summary
 T map(K key, V value)
          Invoked once for each input cache entry K,V transforms that input into a result T.
 

Method Detail

map

T map(K key,
      V value)
Invoked once for each input cache entry K,V transforms that input into a result T.

Parameters:
key - the kay
value - the value
Returns:
result T


Copyright © 2011 JBoss, a division of Red Hat. All Rights Reserved.