Packages

c

bigglue.platforms

BinaryPlatform

abstract class BinaryPlatform[InputL <: Identifiable[InputL], InputR <: Identifiable[InputR], Output <: Identifiable[Output]] extends Platform with BinaryChecker[InputL, InputR, Output]

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. BinaryPlatform
  2. BinaryChecker
  3. OutputStoreChecker
  4. InputStoresChecker
  5. ConfigChecker
  6. Platform
  7. AnyRef
  8. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new BinaryPlatform()

Abstract Value Members

  1. abstract def terminate(): Unit
    Definition Classes
    Platform
  2. abstract 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
    Platform

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. def +(other: String): String
    Implicit
    This member is added by an implicit conversion from BinaryPlatform[InputL, InputR, Output] to any2stringadd[BinaryPlatform[InputL, InputR, Output]] performed by method any2stringadd in scala.Predef.
    Definition Classes
    any2stringadd
  4. def ->[B](y: B): (BinaryPlatform[InputL, InputR, Output], B)
    Implicit
    This member is added by an implicit conversion from BinaryPlatform[InputL, InputR, Output] to ArrowAssoc[BinaryPlatform[InputL, InputR, Output]] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc
    Annotations
    @inline()
  5. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. 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
  8. 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
  9. 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
  10. 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
  11. 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
  12. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  13. 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
  14. def ensuring(cond: (BinaryPlatform[InputL, InputR, Output]) ⇒ Boolean, msg: ⇒ Any): BinaryPlatform[InputL, InputR, Output]
    Implicit
    This member is added by an implicit conversion from BinaryPlatform[InputL, InputR, Output] to Ensuring[BinaryPlatform[InputL, InputR, Output]] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  15. def ensuring(cond: (BinaryPlatform[InputL, InputR, Output]) ⇒ Boolean): BinaryPlatform[InputL, InputR, Output]
    Implicit
    This member is added by an implicit conversion from BinaryPlatform[InputL, InputR, Output] to Ensuring[BinaryPlatform[InputL, InputR, Output]] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  16. def ensuring(cond: Boolean, msg: ⇒ Any): BinaryPlatform[InputL, InputR, Output]
    Implicit
    This member is added by an implicit conversion from BinaryPlatform[InputL, InputR, Output] to Ensuring[BinaryPlatform[InputL, InputR, Output]] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  17. def ensuring(cond: Boolean): BinaryPlatform[InputL, InputR, Output]
    Implicit
    This member is added by an implicit conversion from BinaryPlatform[InputL, InputR, Output] to Ensuring[BinaryPlatform[InputL, InputR, Output]] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  18. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  19. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  20. var errorLeftCuratorOpt: Option[ErrorCurator[InputL]]
  21. var errorPairCuratorOpt: Option[ErrorCurator[Pair[InputL, InputR]]]
  22. var errorRightCuratorOpt: Option[ErrorCurator[InputR]]
  23. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  24. def formatted(fmtstr: String): String
    Implicit
    This member is added by an implicit conversion from BinaryPlatform[InputL, InputR, Output] to StringFormat[BinaryPlatform[InputL, InputR, Output]] performed by method StringFormat in scala.Predef.
    Definition Classes
    StringFormat
    Annotations
    @inline()
  25. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
  26. def getInputLMap(): DataStore[InputL]
  27. def getInputRMap(): DataStore[InputR]
  28. def getInputs(): (Seq[InputL], Seq[InputR], Seq[Pair[InputL, InputR]])
  29. def getLeftErrorCurator(): ErrorCurator[InputL]
  30. def getOutputMap(): DataStore[Output]
  31. def getPairConnector(): Connector[Pair[InputL, InputR]]
  32. def getPairErrorCurator(): ErrorCurator[Pair[InputL, InputR]]
  33. def getProvenanceCurator(): ProvenanceCurator[Pair[InputL, InputR], Output]
  34. def getRightErrorCurator(): ErrorCurator[InputR]
  35. def getUpstreamLConnector(): Connector[InputL]
  36. def getUpstreamRConnector(): Connector[InputR]
  37. def getVersionCurator(): VersionCurator[Output]
  38. def hashCode(): Int
    Definition Classes
    AnyRef → Any
  39. def init(conf: PipeConfig, inputLMap: DataStore[InputL], inputRMap: DataStore[InputR], outputMap: DataStore[Output], builder: PlatformBuilder): Unit
  40. def initConnectors(conf: PipeConfig, builder: PlatformBuilder): Unit
  41. var inputLMapOpt: Option[DataStore[InputL]]
  42. var inputRMapOpt: Option[DataStore[InputR]]
  43. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  44. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  45. final def notify(): Unit
    Definition Classes
    AnyRef
  46. final def notifyAll(): Unit
    Definition Classes
    AnyRef
  47. var outputMapOpt: Option[DataStore[Output]]
  48. var pairConnectorOpt: Option[Connector[Pair[InputL, InputR]]]
  49. 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
  50. var provenanceCuratorOpt: Option[ProvenanceCurator[Pair[InputL, InputR], Output]]
  51. def run(): Unit
    Definition Classes
    Platform
  52. 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
  53. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  54. def toString(): String
    Definition Classes
    AnyRef → Any
  55. var upstreamLConnectorOpt: Option[Connector[InputL]]
  56. var upstreamRConnectorOpt: Option[Connector[InputR]]
  57. var versionCuratorOpt: Option[VersionCurator[Output]]
  58. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  59. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  60. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  61. def →[B](y: B): (BinaryPlatform[InputL, InputR, Output], B)
    Implicit
    This member is added by an implicit conversion from BinaryPlatform[InputL, InputR, Output] to ArrowAssoc[BinaryPlatform[InputL, InputR, Output]] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc

Inherited from BinaryChecker[InputL, InputR, Output]

Inherited from OutputStoreChecker[Output]

Inherited from InputStoresChecker[InputL, InputR]

Inherited from ConfigChecker

Inherited from Platform

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from BinaryPlatform[InputL, InputR, Output] to any2stringadd[BinaryPlatform[InputL, InputR, Output]]

Inherited by implicit conversion StringFormat from BinaryPlatform[InputL, InputR, Output] to StringFormat[BinaryPlatform[InputL, InputR, Output]]

Inherited by implicit conversion Ensuring from BinaryPlatform[InputL, InputR, Output] to Ensuring[BinaryPlatform[InputL, InputR, Output]]

Inherited by implicit conversion ArrowAssoc from BinaryPlatform[InputL, InputR, Output] to ArrowAssoc[BinaryPlatform[InputL, InputR, Output]]

Ungrouped