abstract class Platform extends AnyRef
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.
- Alphabetic
- By Inheritance
- Platform
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Instance Constructors
- new Platform()
Abstract Value Members
-
abstract
def
persist(): Unit
This is called by the computation's persist step.
This is called by the computation's persist step. In particular, this tends to see how much of the data set actually needs to be re-sent.
- abstract def terminate(): Unit
-
abstract
def
wake(): Unit
This function is called when the upstream connector lets the platform know that there's data to be computed.
Concrete Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
- def +(other: String): String
- def ->[B](y: B): (Platform, B)
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
var
computationOpt: Option[Computation]
What computation this platform ends up running.
What computation this platform ends up running. (Mapper, Reducer, PairwiseComposer) This ends up being set in init() by both UnaryPlatform and BinaryPlatform.
- def ensuring(cond: (Platform) ⇒ Boolean, msg: ⇒ Any): Platform
- def ensuring(cond: (Platform) ⇒ Boolean): Platform
- def ensuring(cond: Boolean, msg: ⇒ Any): Platform
- def ensuring(cond: Boolean): Platform
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
- def formatted(fmtstr: String): String
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- def run(): Unit
-
def
setComputation(computation: Computation): Platform
This ends up being called in the init step of the Mapper, Reducer, or PairwiseComposer This links the actual computation and platform together.
This ends up being called in the init step of the Mapper, Reducer, or PairwiseComposer This links the actual computation and platform together.
- computation
The computation that is linked with the platform. (This is usually called through platform.setComputation(this))
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
- def →[B](y: B): (Platform, B)