platforms

abstract class BinaryPlatform [InputL <: Identifiable[InputL], InputR <: Identifiable[InputR], Output <: Identifiable[Output]] extends Platform with BinaryChecker[InputL, InputR, Output]
abstract class Platform extends AnyRef
This is the place where we pass the data in through the computation engine.
This is the place where we pass the data in through the computation engine. The actual computation engine used is defined in the subclasses of the platform. It has two connectors, upstream and downstream, which influence how the code ends up working. This is created as you call pipe.init() in the example code and can be found in a MapperPipe.mapper.platform, or in ReducerPipe.reducer.platform. More specifically, this is the abstraction above UnaryPlatforms and BinaryPlatforms. In the example code, only UnaryPlatforms have been used.
abstract class UnaryPlatform [Input <: Identifiable[Input], Output <: Identifiable[Output]] extends Platform with UnaryChecker[Input, Output]
This is a type of platform that only deals with one input.
This is a type of platform that only deals with one input. These have a computation of either Mapper or Reducer. Within the example, we use the default of bigglue.platforms.instances.bigactors.BigActorMapperPlatform and bigglue.platforms.instances.bigactors.BigActorReducerPlatform.
Input
The type of the data that's being sent in.
Output
The type of the data that's being sent out.

Packages