class BigActorPairwiseComposerPlatform[InputL <: Identifiable[InputL], InputR <: Identifiable[InputR], Output <: Identifiable[Output]] extends BigActorBinaryPlatform[InputL, InputR, Output]
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- BigActorPairwiseComposerPlatform
- BigActorBinaryPlatform
- BigActor
- BinaryPlatform
- BinaryChecker
- OutputStoreChecker
- InputStoresChecker
- ConfigChecker
- Platform
- AnyRef
- Any
Implicitly
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new BigActorPairwiseComposerPlatform(name: String = ...)
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
def
+(other: String): String
- Implicit
- This member is added by an implicit conversion from BigActorPairwiseComposerPlatform[InputL, InputR, Output] to any2stringadd[BigActorPairwiseComposerPlatform[InputL, InputR, Output]] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
-
def
->[B](y: B): (BigActorPairwiseComposerPlatform[InputL, InputR, Output], B)
- Implicit
- This member is added by an implicit conversion from BigActorPairwiseComposerPlatform[InputL, InputR, Output] to ArrowAssoc[BigActorPairwiseComposerPlatform[InputL, InputR, Output]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
implicit
def
actorSystem: ActorSystem
- Definition Classes
- BigActor
-
implicit
val
actorSystemOpt: Option[ActorSystem]
- Definition Classes
- BigActor
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
check(conf: PipeConfig, inputLMap: DataStore[InputL], inputRMap: DataStore[InputR], outputMap: DataStore[Output]): Unit
Check routine for binary data processors
Check routine for binary data processors
- conf
the config file to check
- inputLMap
the left input store to check
- inputRMap
the right input store to check
- outputMap
the output store to check
- Definition Classes
- BinaryChecker
-
def
checkConfig(conf: PipeConfig): Unit
Check that paths in configuration file relevant to host class are well-formed.
Check that paths in configuration file relevant to host class are well-formed. Default does nothing.
- conf
the config file to check
- Definition Classes
- ConfigChecker
-
def
checkInputL(inputLMap: DataStore[InputL]): Unit
Check that left input store is compatible with the host class.
Check that left input store is compatible with the host class. Default does nothing.
- inputLMap
the input store to check
- Definition Classes
- InputStoresChecker
-
def
checkInputR(inputRMap: DataStore[InputR]): Unit
Check that right input store is compatible with the host class.
Check that right input store is compatible with the host class. Default does nothing.
- inputRMap
the input store to check
- Definition Classes
- InputStoresChecker
-
def
checkOutput(outputMap: DataStore[Output]): Unit
Check that output store is compatible with the host class.
Check that output store is compatible with the host class. Default does nothing.
- outputMap
the output store to check
- Definition Classes
- OutputStoreChecker
-
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.
- Definition Classes
- Platform
-
def
compute(job: Pair[InputL, InputR]): Unit
- Definition Classes
- BigActor
-
def
compute_(input: Pair[InputL, InputR]): Unit
- Definition Classes
- BigActorPairwiseComposerPlatform → BigActorBinaryPlatform → BigActor
-
def
computer: ActorRef
This gets the BigActorWorker.
This gets the BigActorWorker.
- Definition Classes
- BigActor
-
val
computerOpt: Option[ActorRef]
- Definition Classes
- BigActor
-
def
ensuring(cond: (BigActorPairwiseComposerPlatform[InputL, InputR, Output]) ⇒ Boolean, msg: ⇒ Any): BigActorPairwiseComposerPlatform[InputL, InputR, Output]
- Implicit
- This member is added by an implicit conversion from BigActorPairwiseComposerPlatform[InputL, InputR, Output] to Ensuring[BigActorPairwiseComposerPlatform[InputL, InputR, Output]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: (BigActorPairwiseComposerPlatform[InputL, InputR, Output]) ⇒ Boolean): BigActorPairwiseComposerPlatform[InputL, InputR, Output]
- Implicit
- This member is added by an implicit conversion from BigActorPairwiseComposerPlatform[InputL, InputR, Output] to Ensuring[BigActorPairwiseComposerPlatform[InputL, InputR, Output]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean, msg: ⇒ Any): BigActorPairwiseComposerPlatform[InputL, InputR, Output]
- Implicit
- This member is added by an implicit conversion from BigActorPairwiseComposerPlatform[InputL, InputR, Output] to Ensuring[BigActorPairwiseComposerPlatform[InputL, InputR, Output]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean): BigActorPairwiseComposerPlatform[InputL, InputR, Output]
- Implicit
- This member is added by an implicit conversion from BigActorPairwiseComposerPlatform[InputL, InputR, Output] to Ensuring[BigActorPairwiseComposerPlatform[InputL, InputR, Output]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
var
errorLeftCuratorOpt: Option[ErrorCurator[InputL]]
- Definition Classes
- BinaryPlatform
-
var
errorPairCuratorOpt: Option[ErrorCurator[Pair[InputL, InputR]]]
- Definition Classes
- BinaryPlatform
-
var
errorRightCuratorOpt: Option[ErrorCurator[InputR]]
- Definition Classes
- BinaryPlatform
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from BigActorPairwiseComposerPlatform[InputL, InputR, Output] to StringFormat[BigActorPairwiseComposerPlatform[InputL, InputR, Output]] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
getErrorCurator(): ErrorCurator[Pair[InputL, InputR]]
- Definition Classes
- BigActorBinaryPlatform → BigActor
-
def
getInputLMap(): DataStore[InputL]
- Definition Classes
- BinaryPlatform
-
def
getInputRMap(): DataStore[InputR]
- Definition Classes
- BinaryPlatform
-
def
getInputs(): (Seq[InputL], Seq[InputR], Seq[Pair[InputL, InputR]])
- Definition Classes
- BinaryPlatform
-
def
getLeftErrorCurator(): ErrorCurator[InputL]
- Definition Classes
- BinaryPlatform
-
def
getOutputMap(): DataStore[Output]
- Definition Classes
- BinaryPlatform
-
def
getPairConnector(): Connector[Pair[InputL, InputR]]
- Definition Classes
- BinaryPlatform
-
def
getPairErrorCurator(): ErrorCurator[Pair[InputL, InputR]]
- Definition Classes
- BinaryPlatform
-
def
getProvenanceCurator(): ProvenanceCurator[Pair[InputL, InputR], Output]
- Definition Classes
- BinaryPlatform
-
def
getRightErrorCurator(): ErrorCurator[InputR]
- Definition Classes
- BinaryPlatform
-
def
getUpstreamLConnector(): Connector[InputL]
- Definition Classes
- BinaryPlatform
-
def
getUpstreamRConnector(): Connector[InputR]
- Definition Classes
- BinaryPlatform
-
def
getVersionCurator(): VersionCurator[Output]
- Definition Classes
- BinaryPlatform
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
val
infoConfig: Config
- Definition Classes
- BigActor
-
def
init(conf: PipeConfig, inputLMap: DataStore[InputL], inputRMap: DataStore[InputR], outputMap: DataStore[Output], builder: PlatformBuilder): Unit
- Definition Classes
- BigActorBinaryPlatform → BinaryPlatform
-
def
initConnectors(conf: PipeConfig, builder: PlatformBuilder): Unit
- Definition Classes
- BigActorBinaryPlatform → BinaryPlatform
-
var
inputLMapOpt: Option[DataStore[InputL]]
- Definition Classes
- BinaryPlatform
-
var
inputLOccurrences: Map[InputL, Integer]
- Definition Classes
- BigActorBinaryPlatform
-
var
inputRMapOpt: Option[DataStore[InputR]]
- Definition Classes
- BinaryPlatform
-
var
inputROccurrences: Map[InputR, Integer]
- Definition Classes
- BigActorBinaryPlatform
-
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
-
var
outputMapOpt: Option[DataStore[Output]]
- Definition Classes
- BinaryPlatform
-
var
pairConnectorOpt: Option[Connector[Pair[InputL, InputR]]]
- Definition Classes
- BinaryPlatform
-
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.
- Definition Classes
- BinaryPlatform → Platform
-
var
provenanceCuratorOpt: Option[ProvenanceCurator[Pair[InputL, InputR], Output]]
- Definition Classes
- BinaryPlatform
-
def
run(): Unit
- Definition Classes
- BigActorBinaryPlatform → Platform
-
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))
- Definition Classes
- Platform
-
var
superActorOpt: Option[ActorRef]
- Definition Classes
- BigActorBinaryPlatform
-
def
supervisor: ActorRef
- Definition Classes
- BigActorBinaryPlatform
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
terminate(): Unit
- Definition Classes
- BigActorBinaryPlatform → Platform
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
def
updateConfigAndGetActorNames(conf: Config, name: String): List[String]
- Definition Classes
- BigActor
-
var
upstreamLConnectorOpt: Option[Connector[InputL]]
- Definition Classes
- BinaryPlatform
-
var
upstreamRConnectorOpt: Option[Connector[InputR]]
- Definition Classes
- BinaryPlatform
-
var
versionCuratorOpt: Option[VersionCurator[Output]]
- Definition Classes
- BinaryPlatform
-
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
wake(): Unit
This function is called when the upstream connector lets the platform know that there's data to be computed.
This function is called when the upstream connector lets the platform know that there's data to be computed.
- Definition Classes
- BigActorBinaryPlatform → Platform
-
def
→[B](y: B): (BigActorPairwiseComposerPlatform[InputL, InputR, Output], B)
- Implicit
- This member is added by an implicit conversion from BigActorPairwiseComposerPlatform[InputL, InputR, Output] to ArrowAssoc[BigActorPairwiseComposerPlatform[InputL, InputR, Output]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc