Creates a MapReducePipe instance by lifting the provided mapper function into a form that returns a Try result. The following apply method allows for a f which needs to be lifted to T=>Try[R].
Creates a MapReducePipe instance by lifting the provided mapper function into a form that returns a Try result. The following apply method allows for a f which needs to be lifted to T=>Try[R].
Value parameters
actors
an implicit Actors instance to manage the underlying actor infrastructure
f
a mapper function that takes a key-value pair of types (K0, V0) and produces a new key-value pair of types (K1, W)
g
a reducer function that combines two values, one of type V1 (super-type of W) and the other of type W, into a single value of type V1
n
the stage number for the map-reduce process
timeout
an implicit Timeout specifying the maximum duration for actor operations
Attributes
Returns
a MapReducePipe instance configured with the lifted mapper and reducer functions for the specified stage