The Soss.Client.Concurrent.MapReduce collection contains three abstract classes that are needed to perform MapReduce operations using the Soss.Client.Concurrent.NamedMap.RunMapReduce(...) methods.
Defines the signature for a combiner class, which can be used to perform the optional "combine" step in a MapReduce operation. A combiner compacts the locally-produced map output to minimize unnecessary data transfer. Since this is an optimization, no assumption should be made by the caller about how often (if at all) a combiner is invoked. The output of the MapReduce task with a combiner enabled will be identical to the output of the MapReduce task running without a combiner.
|MapperIK, IV, MK, MV|
Defines the signature for a mapper class, which is used to perform the map step of a MapReduce operation. A mapper ingests key-value pairs from the input named map and emits a number of intermediate key-value pairs to be processed by a combiner or reducer.
|ReducerMK, MV, OK, OV|
Defines the signature for a reducer class, which is used to perform the reduce step of a MapReduce operation. A reducer ingests the value list for a key and emits key-value pairs that are written to the output named map.
Helper context type for emitting key value pairs, which is used by mappers and reducers.