Soss.Client.Concurrent.MapReduce Namespace

ScaleOut Software NamedCache API
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.
Classes

  ClassDescription
Public classCombinerMK, MV
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.
Public classMapperIK, 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.
Public classReducerMK, 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.
Interfaces

  InterfaceDescription
Public interfaceIContextK, V
Helper context type for emitting key value pairs, which is used by mappers and reducers.