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 UnaryComputation[Input, Output] to any2stringadd[UnaryComputation[Input, Output]] performed by method any2stringadd in scala.Predef.

   Definition Classes

   any2stringadd

4.  def ->[B](y: B): (UnaryComputation[Input, Output], B)

   Implicit

   This member is added by an implicit conversion from UnaryComputation[Input, Output] to ArrowAssoc[UnaryComputation[Input, 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, inputMap: DataStore[Input], outputMap: DataStore[Output]): Unit

   Check routine for unary data processors

   Check routine for unary data processors

   conf

   the config file to check

   inputMap

   the input store to check

   outputMap

   the output store to check

   Definition Classes

   UnaryChecker

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 checkInput(inputMap: DataStore[Input]): Unit

   Check that input store is compatible with the host class.

   Check that input store is compatible with the host class. Default does nothing.

   inputMap

   the input store to check

   Definition Classes

   InputStoreChecker

10.  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

11.  def clone(): AnyRef

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

12.  val configOpt: Option[PipeConfig]

    Definition Classes

    ConfigBuilds

13.  var configOption: ConfOpt

    Definition Classes

    Computation

14.  def constructBuilder(config: PipeConfig = null): PlatformBuilder

    Definition Classes

    ConfigBuildsPlatform → ConfigBuilds

15.  def ensuring(cond: (UnaryComputation[Input, Output]) ⇒ Boolean, msg: ⇒ Any): UnaryComputation[Input, Output]

    Implicit

    This member is added by an implicit conversion from UnaryComputation[Input, Output] to Ensuring[UnaryComputation[Input, Output]] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

16.  def ensuring(cond: (UnaryComputation[Input, Output]) ⇒ Boolean): UnaryComputation[Input, Output]

    Implicit

    This member is added by an implicit conversion from UnaryComputation[Input, Output] to Ensuring[UnaryComputation[Input, Output]] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

17.  def ensuring(cond: Boolean, msg: ⇒ Any): UnaryComputation[Input, Output]

    Implicit

    This member is added by an implicit conversion from UnaryComputation[Input, Output] to Ensuring[UnaryComputation[Input, Output]] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

18.  def ensuring(cond: Boolean): UnaryComputation[Input, Output]

    Implicit

    This member is added by an implicit conversion from UnaryComputation[Input, Output] to Ensuring[UnaryComputation[Input, Output]] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

19.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

20.  def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

21.  def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

22.  def formatted(fmtstr: String): String

    Implicit

    This member is added by an implicit conversion from UnaryComputation[Input, Output] to StringFormat[UnaryComputation[Input, Output]] performed by method StringFormat in scala.Predef.

    Definition Classes

    StringFormat

    Annotations

    @inline()

23.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

24.  def getConfig(config: PipeConfig): PipeConfig

    Definition Classes

    ConfigBuilds

25.  def getUnaryPlatform(): UnaryPlatform[Input, Output]
26.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

27.  def init(conf: PipeConfig, inputMap: DataStore[Input], outputMap: DataStore[Output], platform: UnaryPlatform[Input, Output]): Unit

    This connects the newly initialized platform to the Input Data Store by making it so the Input Data Store sends data down to the platform.

    This connects the newly initialized platform to the Input Data Store by making it so the Input Data Store sends data down to the platform.

    conf

    The configuration file.

    inputMap

    The Input Data Store

    outputMap

    The Output Data Store

    platform

    The Platform added by the Mapper or Reducer computations.

28.  def init(config: PipeConfig, platform: Platform): Unit

    Definition Classes

    Computation

29.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

30.  def name(newName: String): UnaryComputation[Input, Output]
31.  var name: String
32.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

33.  final def notify(): Unit

    Definition Classes

    AnyRef

34.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

35.  def persist(): Unit

    If the computation has been initialized, it calls Platform.persist on the platform.

    If the computation has been initialized, it calls Platform.persist on the platform. This gives the platform the responsibility of what data to send/resend down the pipeline.

    Definition Classes

    Computation

36.  var platformOpt: Option[Platform]

    Definition Classes

    Computation

37.  def run(): Unit

    Definition Classes

    Computation

38.  def setConfig(pipeConfig: PipeConfig): Unit

    Definition Classes

    ConfigBuilds

39.  final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

40.  def terminate(): Unit

    Definition Classes

    Computation

41.  def toStep(conf: PipeConfig, step: String): PipeConfig

    Definition Classes

    Computation

42.  def toString(): String

    Definition Classes

    AnyRef → Any

43.  var unaryPlatformOpt: Option[UnaryPlatform[Input, Output]]
44.  val versionOpt: Option[String]

    Definition Classes

    Computation

45.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

46.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

47.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

48.  def →[B](y: B): (UnaryComputation[Input, Output], B)

    Implicit

    This member is added by an implicit conversion from UnaryComputation[Input, Output] to ArrowAssoc[UnaryComputation[Input, Output]] performed by method ArrowAssoc in scala.Predef.

    Definition Classes

    ArrowAssoc