com.nicta.scoobi.impl.plan.comp

Combine

Related Docs: object Combine | package comp

case class Combine(in: CompNode, dofn: DoFunction, wfk: WireReaderWriter, wfv: WireReaderWriter, wfu: WireReaderWriter, nodeSinks: Seq[Sink] = Seq(), bridgeStoreId: String = randomUUID.toString) extends ProcessNodeImpl with Product with Serializable

The Combine node type specifies the building of a CompNode as a result of applying an associative function to the values of an existing key-values CompNode

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

Instance Constructors

  1. new Combine(in: CompNode, dofn: DoFunction, wfk: WireReaderWriter, wfv: WireReaderWriter, wfu: WireReaderWriter, nodeSinks: Seq[Sink] = Seq(), bridgeStoreId: String = randomUUID.toString)

Type Members

  1. type C = ProcessNode

    Definition Classes
    ProcessNodeCompNode

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

    Definition Classes
    Attributable
    Annotations
    @inline()
  4. final def ->[U](a: (Combine.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. val bridgeStoreId: String

    unique identifier for the bridgeStore storing data for this node

    unique identifier for the bridgeStore storing data for this node

    Definition Classes
    CombineProcessNodeImplProcessNode
  10. def bridgeToString: String

    display the bridge id

    display the bridge id

    Definition Classes
    ProcessNodeImpl
  11. def children: Iterator[Attributable]

    Definition Classes
    Attributable
  12. def clone(): Attributable

    Definition Classes
    Attributable → AnyRef
  13. def combine(values: Iterable[Any], emitter: EmitterWriter): Unit

  14. val dofn: DoFunction

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

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

    Definition Classes
    CompNode → 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. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  20. def hasCheckpoint: Boolean

    Definition Classes
    CompNode
  21. def hasChildren: Boolean

    Definition Classes
    Attributable
  22. def hashCode(): Int

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

    unique identifier for this computation node

    unique identifier for this computation node

    Definition Classes
    ProcessNodeImplCompNode
  24. val in: CompNode

  25. var index: Int

    Definition Classes
    Attributable
  26. def initTreeProperties(): Unit

    Definition Classes
    Attributable
  27. def isFirst: Boolean

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

    Definition Classes
    Any
  29. def isLast: Boolean

    Definition Classes
    Attributable
  30. def isRoot: Boolean

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

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

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

    Definition Classes
    Attributable
  34. var next: Attributable

    Definition Classes
    Attributable
  35. val nodeSinks: Seq[Sink]

    list of additional sinks for this node

    list of additional sinks for this node

    Definition Classes
    CombineProcessNodeImplProcessNode
  36. def nodeSinksString: String

    display the sinks if any

    display the sinks if any

    Definition Classes
    ProcessNodeImpl
  37. final def notify(): Unit

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

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

    Definition Classes
    Attributable
  40. var parent: Attributable

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

    Definition Classes
    Attributable
  42. var prev: Attributable

    Definition Classes
    Attributable
  43. def reduce(values: Iterable[_], context: InputOutputContext): Option[Any]

  44. lazy val sinks: Seq[Sink]

    returns

    all the additional sinks + the bridgeStore

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

    Definition Classes
    AnyRef
  46. def toParallelDo: ParallelDo

    returns

    a ParallelDo node where the mapping uses the combine function to combine the Iterable[V] values

  47. val toString: String

    Definition Classes
    Combine → AnyRef → Any
  48. def updateSinks(f: (Seq[Sink]) ⇒ Seq[Sink]): Combine

    Definition Classes
    CombineCompNode
  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( ... )
  52. 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
    CombineCompNode
  53. val wfk: WireReaderWriter

  54. val wfu: WireReaderWriter

  55. val wfv: WireReaderWriter

Inherited from Serializable

Inherited from Serializable

Inherited from ProcessNodeImpl

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