WorkerPool

com.phasmid.majabigwaduce.core.WorkerPool
See theWorkerPool companion object
trait WorkerPool

Where a Master's mappers and reducers come from.

acquire is called once, from the Master's setup (i.e. on the Master's own thread, so an implementation may use context directly). It returns a Future so that an implementation can obtain workers asynchronously -- e.g. by asking remote nodes to spawn them.

Attributes

Companion
object
Graph
Supertypes
class Object
trait Matchable
class Any
Known subtypes

Members list

Value members

Abstract 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]]