com.phasmid.majabigwaduce.core.MapReducePipeFold
See theMapReducePipeFold companion class
Singleton object for creating and managing MapReducePipeFold instances.
This companion object provides utility methods to initialize MapReducePipeFold instances, given appropriate functions for mapping and reducing, stage numbers, actor system configurations, and timeout settings.
Attributes
Companion
class
Graph
Reset zoom Hide graph Show graph
Supertypes
class Object
trait Matchable
class Any
Self type
Members list
Creates a MapReducePipeFold instance by applying the provided mapper and reducer functions.
Creates a MapReducePipeFold instance by applying the provided mapper and reducer functions.
Value parameters
actors
an instance of Actors used for managing the actor system
f
the mapper function that transforms an input key-value pair of type (K0, V0) into an intermediate key-value pair of type (K1, W)
g
the reducer function that combines a value of type V1 with a value of type W to produce a new value of type V1
n
the stage number for this map-reduce operation
timeout
the timeout configuration for the operation
Attributes
Returns
a new instance of MapReducePipeFold configured with the given functions and parameters