package bigactors
- Alphabetic
- Public
- All
Type Members
-
trait
BigActor
[Input] extends AnyRef
How stuff gets computed with BigActorPlatforms
- abstract class BigActorBinaryPlatform [InputL <: Identifiable[InputL], InputR <: Identifiable[InputR], Output <: Identifiable[Output]] extends BinaryPlatform[InputL, InputR, Output] with BigActor[Pair[InputL, InputR]]
-
class
BigActorMapperPlatform
[Input <: Identifiable[Input], Output <: Identifiable[Output]] extends BigActorUnaryPlatform[Input, Output]
This is the default platform for the mapper.
This is the default platform for the mapper. It attempts to do the computations on the inputs asynchronously. This is a subclass of BigActorUnaryPlatform.
- Input
The type of the data that needs to be computed. In the case of gitID:--Clone()-->clonedMap and bigglue.examples.GitRepo for clonedMap:--CommitExtraction()-->commitInfoMap. This needs to be an Identifiable type.
- Output
The type of the data that ends up being computed. bigglue.examples.GitRepo for gitID:--Clone()-->clonedMap, and bigglue.examples.GitCommitInfo for clonedMap:--CommitExtraction()-->commitInfoMap This also needs to be an Identifiable type.
- class BigActorPairwiseComposerPlatform [InputL <: Identifiable[InputL], InputR <: Identifiable[InputR], Output <: Identifiable[Output]] extends BigActorBinaryPlatform[InputL, InputR, Output]
-
class
BigActorReducerPlatform
[Input <: Identifiable[Input], Output <: Identifiable[Output]] extends BigActorUnaryPlatform[Input, Output]
This is the default platform for the reducer.
This is the default platform for the reducer.
- Input
The type of the data that needs to be computed. bigglue.examples.GitCommitInfo in this case, which is the type of commitInfoMap. This needs to be an Identifiable type.
- Output
The type of the data that the input ends up being reduced to. Within the example, this will be bigglue.examples.GitCommitGroups.
-
class
BigActorSupervisorActor
[Input <: Identifiable[Input], Output] extends Actor
The actor on top of everything that
The actor on top of everything that
- Input
The type of the data that's being sent in. This needs to be an Identifiable type.
- Output
The type of the data that's being sent out. This needs to be an Identifiable type.
-
abstract
class
BigActorUnaryPlatform
[Input <: Identifiable[Input], Output <: Identifiable[Output]] extends UnaryPlatform[Input, Output] with BigActor[Input]
This is the default platform of computation.
This is the default platform of computation. This attempts to compute through a list of inputs asynchronously. In more detail, Has a supervisor BigActorSupervisorActor and a list of workers, BigActorWorker. However, these are not necessary to understand the example, and is just an implementation detail.
- Input
The type of the data that's being sent in. This needs to be an Identifiable type.
- Output
The type of the data that's being sent out. This needs to be an Identifiable type.
-
class
BigActorWorker
[Input <: Identifiable[Input], Output <: Identifiable[Output]] extends Actor
This is the worker that actually does the jobs of the platform.
This is the worker that actually does the jobs of the platform.
- Input
The type of the data that's being sent in. This needs to be an Identifiable type.
- Output
The type of the data that's being sent out. This needs to be an Identifiable type.
-
class
BigActorWorkerActor
[Input <: Identifiable[Input], Output <: Identifiable[Output]] extends Actor
The actors that actually do the work of computing the tasks.
The actors that actually do the work of computing the tasks. It sends stuff to the BigActorWorkers to be computed, keeping track of time.
- Input
The type of the data that's being sent in. This needs to be an Identifiable type.
- Output
The type of the data that's being sent out. This needs to be an Identifiable type.
Value Members
- object BigActorPlatform
-
object
ConfigHelper
Created by chanceroberts on 8/10/17.