com.nicta.scoobi.impl.plan.mscr

Mscr

case class Mscr extends Attributable with Product with Serializable

This class represents an MSCR job with a Seq of input channels and a Seq of output channels

Each mscr has a unique id, which is used for equality.

A Mscr has both input and output channels where input channels are doing mapping operations while output channels are doing grouping and reducing operations.

In order to optimise the processing a same value can be computed by several mapping functions and be directed to different grouping / reducing functions, each of them identified by a tag.

Linear Supertypes
Serializable, Serializable, Attributable, Cloneable, Cloneable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Mscr
  2. Serializable
  3. Serializable
  4. Attributable
  5. Cloneable
  6. Cloneable
  7. Product
  8. Equals
  9. AnyRef
  10. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any

  3. final def ##(): Int

    Definition Classes
    AnyRef → Any

  4. final def ->[T, U](a: (T) ⇒ U)(implicit b: (Mscr.this.type) ⇒ T): U

    Definition Classes
    Attributable
    Annotations
    @inline()

  5. final def ->[U](a: (Mscr.this.type) ⇒ U): U

    Definition Classes
    Attributable
    Annotations
    @inline()

  6. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  7. final def ==(arg0: Any): Boolean

    Definition Classes
    Any

  8. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  9. lazy val bridges: Seq[Bridge]

    bridges (source+sink) for this Mscr

  10. def channels: Seq[Channel]

    returns

    all the channels

  11. def children: Iterator[Attributable]

    Definition Classes
    Attributable

  12. def clone(): Attributable

    Definition Classes
    Attributable → AnyRef

  13. def combiners: Seq[Combine]

    returns

    all the combiners of this mscr

  14. def combinersByTag: Map[Int, Combine]

    returns

    all the combiners of this mscr by tag

  15. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  16. def equals(a: Any): Boolean

    Definition Classes
    Mscr → Equals → AnyRef → Any

  17. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  18. def firstChild[T]: T

    Definition Classes
    Attributable

  19. def floatingInputChannels: Seq[FloatingInputChannel]

    returns

    only the floating input channels

  20. def gbkOutputChannels: Seq[GbkOutputChannel]

    returns

    only the GbkOutputChannels

  21. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any

  22. def hasChildren: Boolean

    Definition Classes
    Attributable

  23. def hashCode(): Int

    Definition Classes
    Mscr → AnyRef → Any

  24. val id: Int

  25. var index: Int

    Definition Classes
    Attributable

  26. def initTreeProperties(): Unit

    Definition Classes
    Attributable

  27. val inputChannels: Seq[InputChannel]

  28. lazy val inputNodes: Seq[CompNode]

    distinct input nodes for this Mscr

  29. def isEmpty: Boolean

    returns

    true if the Mscr is empty

  30. def isFirst: Boolean

    Definition Classes
    Attributable

  31. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  32. def isLast: Boolean

    Definition Classes
    Attributable

  33. def isRoot: Boolean

    Definition Classes
    Attributable

  34. lazy val keyTypes: KeyTypes

    map of wireformats and groupings for each key tag of this Mscr

  35. def lastChild[T]: T

    Definition Classes
    Attributable

  36. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  37. def next[T]: T

    Definition Classes
    Attributable

  38. var next: Attributable

    Definition Classes
    Attributable

  39. def nodes: Seq[ProcessNode]

    returns

    all the nodes of this Mscr

  40. final def notify(): Unit

    Definition Classes
    AnyRef

  41. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  42. val outputChannels: Seq[OutputChannel]

  43. lazy val outputNodes: Seq[CompNode]

    distinct input nodes for this Mscr

  44. def parent[T]: T

    Definition Classes
    Attributable

  45. var parent: Attributable

    Definition Classes
    Attributable

  46. def prev[T]: T

    Definition Classes
    Attributable

  47. var prev: Attributable

    Definition Classes
    Attributable

  48. lazy val sinks: Seq[Sink]

    datasinks for this Mscr

  49. lazy val sources: Seq[Source]

    datasources for this Mscr

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

    Definition Classes
    AnyRef

  51. def toString(): String

    Definition Classes
    Mscr → AnyRef → Any

  52. lazy val valueTypes: ValueTypes

    map of wireformats for each input tag of this Mscr

  53. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  55. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from Serializable

Inherited from Serializable

Inherited from Attributable

Inherited from Cloneable

Inherited from Cloneable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped