Majabigwaduce
API
Generated with
Majabigwaduce/com.phasmid.majabigwaduce/com.phasmid.majabigwaduce.core/LocalWorkerPool

LocalWorkerPool

com.phasmid.majabigwaduce.core.LocalWorkerPool
object LocalWorkerPool extends WorkerPool

The default WorkerPool: spawns the workers as local children of the Master, so they are stopped when the Master stops. This is what Master did directly before 2.1.0.

Attributes

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

Members list

Value members

Concrete methods

def acquire[K1, V1, K2, W, V2](context: ActorContext[_], actors: Actors, mapper: MapperDef[K1, V1, K2, W], nMappers: Int, reducer: ReducerDef[K2, W, V2], nReducers: Int): Future[Workers[K1, V1, K2, W, V2]]
Generated with