com.phasmid.majabigwaduce.cluster
Members list
Type members
Classlikes
A ClusterWorker offers reducers to the Masters of a cluster. Start one (with ClusterWorker.start) on every node which should run reducers -- including, if you like, the node which runs the Master. It registers itself with the Receptionist, so that a ClusterWorkerPool can find it.
A ClusterWorker offers reducers to the Masters of a cluster. Start one (with ClusterWorker.start) on every node which should run reducers -- including, if you like, the node which runs the Master. It registers itself with the Receptionist, so that a ClusterWorkerPool can find it.
Attributes
- Supertypes
-
class Objecttrait Matchableclass Any
- Self type
-
ClusterWorker.type
The WorkerPool which a Master uses when its ActorSystem is a cluster member (see WorkerPool.forSystem).
The WorkerPool which a Master uses when its ActorSystem is a cluster member (see WorkerPool.forSystem).
The mappers still run locally, on the Master's node. The reducers are spread across the ClusterWorkers found through the Receptionist: the reducer definition (including the reducer function) is sent to each worker, which spawns its share of the reducers and replies with their refs. The Master then drives them exactly as it drives local reducers.
Attributes
- Supertypes
- Self type
-
ClusterWorkerPool.type
The reply to SpawnReducers.
The reply to SpawnReducers.
Attributes
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass Objecttrait Matchableclass AnyShow all
Asks a worker to spawn n reducers built from reducer, for the job run by master. The reducers are stopped when master stops (or its node leaves the cluster).
Asks a worker to spawn n reducers built from reducer, for the job run by master. The reducers are stopped when master stops (or its node leaves the cluster).
Value parameters
- master
-
the Master actor which will use the reducers.
- n
-
the number of reducers to spawn.
- reducer
-
the definition of the reducers (including the reducer function itself).
- replyTo
-
where to send the refs of the new reducers.
Attributes
- Supertypes
-
trait Producttrait Equalstrait WorkerCommandtrait Serializableclass Objecttrait Matchableclass AnyShow all
The command protocol of a ClusterWorker. NOTE these messages travel between nodes, using Java serialization (see doc/Clustering.md).
The command protocol of a ClusterWorker. NOTE these messages travel between nodes, using Java serialization (see doc/Clustering.md).
Attributes
- Supertypes
-
trait Serializableclass Objecttrait Matchableclass Any
- Known subtypes
-