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
Class | Description | |
---|---|---|
CombinerMK, 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.
| |
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.
|
Interfaces
Interface | Description | |
---|---|---|
IContextK, V |
Helper context type for emitting key value pairs, which is used by
mappers and reducers.
|