com.nicta.scoobi.impl.plan.mscr

Mscr

Related Docs: object Mscr | package 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: Any): Boolean

    Definition Classes
    AnyRef → Any

  2. final def ##(): Int

    Definition Classes
    AnyRef → Any

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

    Definition Classes
    Attributable
    Annotations
    @inline()

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

    Definition Classes
    Attributable
    Annotations
    @inline()

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

    Definition Classes
    AnyRef → Any

  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  7. lazy val bridges: Seq[Bridge]

    bridges (source+sink) for this Mscr

  8. def channels: Seq[Channel]

    returns

    all the channels

  9. def children: Iterator[Attributable]

    Definition Classes
    Attributable

  10. def clone(): Attributable

    Definition Classes
    Attributable → AnyRef

  11. def combiners: Seq[Combine]

    returns

    all the combiners of this mscr

  12. def combinersByTag: Map[Int, Combine]

    returns

    all the combiners of this mscr by tag

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

    Definition Classes
    AnyRef

  14. def equals(a: Any): Boolean

    Definition Classes
    Mscr → Equals → AnyRef → Any

  15. def finalize(): Unit

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

  16. def firstChild[T]: T

    Definition Classes
    Attributable

  17. def floatingInputChannels: Seq[FloatingInputChannel]

    returns

    only the floating input channels

  18. def gbkOutputChannels: Seq[GbkOutputChannel]

    returns

    only the GbkOutputChannels

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

    Definition Classes
    AnyRef → Any

  20. def hasChildren: Boolean

    Definition Classes
    Attributable

  21. def hashCode(): Int

    Definition Classes
    Mscr → AnyRef → Any

  22. val id: Int

  23. var index: Int

    Definition Classes
    Attributable

  24. def initTreeProperties(): Unit

    Definition Classes
    Attributable

  25. val inputChannels: Seq[InputChannel]

  26. lazy val inputNodes: Seq[CompNode]

    distinct input nodes for this Mscr

  27. def isEmpty: Boolean

    returns

    true if the Mscr is empty

  28. def isFirst: Boolean

    Definition Classes
    Attributable

  29. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  30. def isLast: Boolean

    Definition Classes
    Attributable

  31. def isRoot: Boolean

    Definition Classes
    Attributable

  32. lazy val keyTypes: KeyTypes

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

  33. def lastChild[T]: T

    Definition Classes
    Attributable

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

    Definition Classes
    AnyRef

  35. def next[T]: T

    Definition Classes
    Attributable

  36. var next: Attributable

    Definition Classes
    Attributable

  37. def nodes: Seq[ProcessNode]

    returns

    all the nodes of this Mscr

  38. final def notify(): Unit

    Definition Classes
    AnyRef

  39. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  40. val outputChannels: Seq[OutputChannel]

  41. lazy val outputNodes: Seq[CompNode]

    distinct input nodes for this Mscr

  42. def parent[T]: T

    Definition Classes
    Attributable

  43. var parent: Attributable

    Definition Classes
    Attributable

  44. def prev[T]: T

    Definition Classes
    Attributable

  45. var prev: Attributable

    Definition Classes
    Attributable

  46. lazy val sinks: Seq[Sink]

    datasinks for this Mscr

  47. lazy val sources: Seq[Source]

    datasources for this Mscr

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

    Definition Classes
    AnyRef

  49. def toString(): String

    Definition Classes
    Mscr → AnyRef → Any

  50. lazy val valueTypes: ValueTypes

    map of wireformats for each input tag of this Mscr

  51. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  53. 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