org.infinispan.distexec.mapreduce
Interface Reducer<KOut,VOut>

All Superinterfaces:

Serializable

All Known Implementing Classes:

IndexingReducer, WordCountReducer

public interface Reducer<KOut,VOut>
extends Serializable

Reduces intermediate key/value results from map phase of MapReduceTask. Infinispan distributed execution environment uses one instance of Reducer per execution node.

Since:

5.0

Author:

Manik Surtani, Vladimir Blagojevic, Sanne Grinovero

See Also:

Mapper, MapReduceTask

Method Summary

VOut	reduce(KOut reducedKey, Iterator<VOut> iter) Combines/reduces all intermediate values for a particular intermediate key to a single value.

Method Detail

reduce

VOut reduce(KOut reducedKey,
            Iterator<VOut> iter)

Combines/reduces all intermediate values for a particular intermediate key to a single value.