com.nicta.scoobi.impl.plan.comp

ProcessNodeImpl

Related Doc: package comp

trait ProcessNodeImpl extends ProcessNode

Processing node in the computation graph.

It has a unique id, a BridgeStore for its outputs and some possible additional sinks.

Linear Supertypes
ProcessNode, CompNode, Attributable, Cloneable, Cloneable, Product, Equals, AnyRef, Any
Known Subclasses
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. ProcessNodeImpl
  2. ProcessNode
  3. CompNode
  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

Type Members

  1. type C = ProcessNode

    Definition Classes
    ProcessNodeCompNode

Abstract Value Members

  1. abstract def bridgeStoreId: String

    unique identifier for the bridgeStore storing data for this node

    unique identifier for the bridgeStore storing data for this node

    Definition Classes
    ProcessNodeImplProcessNode
  2. abstract def canEqual(that: Any): Boolean

    Definition Classes
    Equals
  3. abstract def nodeSinks: Seq[Sink]

    list of additional sinks for this node

    list of additional sinks for this node

    Definition Classes
    ProcessNodeImplProcessNode
  4. abstract def productArity: Int

    Definition Classes
    Product
  5. abstract def productElement(n: Int): Any

    Definition Classes
    Product
  6. abstract def updateSinks(f: (Seq[Sink]) ⇒ Seq[Sink]): C

    Definition Classes
    CompNode
  7. abstract def wf: WireReaderWriter

    object defining how to serialise / deserialise data for that node

    object defining how to serialise / deserialise data for that node

    Definition Classes
    CompNode

Concrete 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: (ProcessNodeImpl.this.type) ⇒ T): U

    Definition Classes
    Attributable
    Annotations
    @inline()
  4. final def ->[U](a: (ProcessNodeImpl.this.type) ⇒ U): U

    Definition Classes
    Attributable
    Annotations
    @inline()
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  6. def addSink(sink: Sink): C

    Definition Classes
    CompNode
  7. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  8. lazy val bridgeStore: Bridge

    ParallelDo, Combine, GroupByKey have a Bridge = sink for previous computations + source for other computations

    ParallelDo, Combine, GroupByKey have a Bridge = sink for previous computations + source for other computations

    Definition Classes
    ProcessNodeImplProcessNode
  9. def bridgeToString: String

    display the bridge id

  10. def children: Iterator[Attributable]

    Definition Classes
    Attributable
  11. def clone(): Attributable

    Definition Classes
    Attributable → AnyRef
  12. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  13. def equals(a: Any): Boolean

    Definition Classes
    CompNode → Equals → AnyRef → Any
  14. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  15. def firstChild[T]: T

    Definition Classes
    Attributable
  16. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  17. def hasCheckpoint: Boolean

    Definition Classes
    CompNode
  18. def hasChildren: Boolean

    Definition Classes
    Attributable
  19. def hashCode(): Int

    Definition Classes
    CompNode → AnyRef → Any
  20. val id: Int

    unique identifier for this computation node

    unique identifier for this computation node

    Definition Classes
    ProcessNodeImplCompNode
  21. var index: Int

    Definition Classes
    Attributable
  22. def initTreeProperties(): Unit

    Definition Classes
    Attributable
  23. def isFirst: Boolean

    Definition Classes
    Attributable
  24. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  25. def isLast: Boolean

    Definition Classes
    Attributable
  26. def isRoot: Boolean

    Definition Classes
    Attributable
  27. def lastChild[T]: T

    Definition Classes
    Attributable
  28. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  29. def next[T]: T

    Definition Classes
    Attributable
  30. var next: Attributable

    Definition Classes
    Attributable
  31. def nodeSinksString: String

    display the sinks if any

  32. final def notify(): Unit

    Definition Classes
    AnyRef
  33. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  34. def parent[T]: T

    Definition Classes
    Attributable
  35. var parent: Attributable

    Definition Classes
    Attributable
  36. def prev[T]: T

    Definition Classes
    Attributable
  37. var prev: Attributable

    Definition Classes
    Attributable
  38. def productIterator: Iterator[Any]

    Definition Classes
    Product
  39. def productPrefix: String

    Definition Classes
    Product
  40. lazy val sinks: Seq[Sink]

    returns

    all the additional sinks + the bridgeStore

    Definition Classes
    ProcessNodeImplCompNode
  41. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  42. def toString(): String

    Definition Classes
    AnyRef → Any
  43. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  44. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  45. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from ProcessNode

Inherited from CompNode

Inherited from Attributable

Inherited from Cloneable

Inherited from Cloneable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped