MapReduceFirstFold

com.phasmid.majabigwaduce.core.MapReduceFirstFold
See theMapReduceFirstFold companion class

Companion object for MapReduceFirstFold, providing factory methods and constants.

Attributes

Companion
class
Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Value members

Concrete methods

def create[V0, K1, W, V1 : Zero](f: V0 => (K1, W), g: (V1, W) => V1)(actors: Actors, timeout: Timeout): MapReduceFirstFold[V0, K1, W, V1]

Creates a MapReduceFirstFold instance using the given mapper function, reducer function, actor configuration, and timeout.

Creates a MapReduceFirstFold instance using the given mapper function, reducer function, actor configuration, and timeout.

Value parameters

actors

the actor configuration used to manage the underlying actors.

f

the mapper function that transforms an input of type V0 into a tuple (K1, W).

g

the reducer function that combines a value of type V1 with a value of type W into a new value of type V1.

timeout

the timeout value that determines the maximum time to wait for an operation to complete.

Attributes

Returns

a MapReduceFirstFold instance parameterized with types V0, K1, W, and V1.