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 children: Iterator[Attributable]

    Definition Classes
    Attributable

  11. def clone(): Attributable

    Definition Classes
    Attributable → AnyRef

  12. def combiners: Seq[Combine]

    returns

    all the combiners of this mscr

  13. def combinersByTag: Map[Int, Combine]

    returns

    all the combiners of this mscr by tag

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

    Definition Classes
    AnyRef

  15. def equals(a: Any): Boolean

    Definition Classes
    Mscr → Equals → AnyRef → Any

  16. def finalize(): Unit

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

  17. def firstChild[T]: T

    Definition Classes
    Attributable

  18. def floatingInputChannels: Seq[FloatingInputChannel]

    returns

    only the floating input channels

  19. def gbkOutputChannels: Seq[GbkOutputChannel]

    returns

    only the GbkOutputChannels

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

    Definition Classes
    AnyRef → Any

  21. def hasChildren: Boolean

    Definition Classes
    Attributable

  22. def hashCode(): Int

    Definition Classes
    Mscr → AnyRef → Any

  23. val id: Int

  24. var index: Int

    Definition Classes
    Attributable

  25. def initTreeProperties(): Unit

    Definition Classes
    Attributable

  26. val inputChannels: Seq[InputChannel]

  27. lazy val inputNodes: Seq[CompNode]

    distinct input nodes for this Mscr

  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. final def notify(): Unit

    Definition Classes
    AnyRef

  38. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  39. val outputChannels: Seq[OutputChannel]

  40. def parent[T]: T

    Definition Classes
    Attributable

  41. var parent: Attributable

    Definition Classes
    Attributable

  42. def prev[T]: T

    Definition Classes
    Attributable

  43. var prev: Attributable

    Definition Classes
    Attributable

  44. lazy val sinks: Seq[Sink]

    datasinks for this Mscr

  45. lazy val sources: Seq[Source]

    datasources for this Mscr

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

    Definition Classes
    AnyRef

  47. def toString(): String

    Definition Classes
    Mscr → AnyRef → Any

  48. lazy val valueTypes: ValueTypes

    map of wireformats for each input tag of this Mscr

  49. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

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