com.nicta.scoobi.impl.plan.comp

GroupByKey

case class GroupByKey(in: CompNode, wfk: WireReaderWriter, gpk: KeyGrouping, wfv: WireReaderWriter, nodeSinks: Seq[Sink] = ..., bridgeStoreId: String = ...) extends ProcessNodeImpl with Product with Serializable

The GroupByKey node type specifies the building of a CompNode as a result of partitioning an exiting key-value CompNode by key

Linear Supertypes
Serializable, Serializable, ProcessNodeImpl, ProcessNode, CompNode, Attributable, Cloneable, Cloneable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. GroupByKey
  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 GroupByKey(in: CompNode, wfk: WireReaderWriter, gpk: KeyGrouping, wfv: WireReaderWriter, nodeSinks: Seq[Sink] = ..., bridgeStoreId: String = ...)

Type Members

  1. type C = ProcessNode

    Definition Classes
    ProcessNode → CompNode

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

    Definition Classes
    Attributable
    Annotations
    @inline()

  5. final def ->[U](a: (GroupByKey.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. def addSink(sink: Sink): C

    Definition Classes
    CompNode

  9. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  10. lazy val bridgeStore: Option[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
    ProcessNodeImpl → ProcessNode

  11. 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
    GroupByKey → ProcessNodeImpl

  12. def bridgeToString: String

    display the bridge id

    display the bridge id

    Definition Classes
    ProcessNodeImpl

  13. def children: Iterator[Attributable]

    Definition Classes
    Attributable

  14. def clone(): Attributable

    Definition Classes
    Attributable → AnyRef

  15. def createBridgeStore: BridgeStore[Nothing]

    create a new bridgeStore if necessary

    create a new bridgeStore if necessary

    Definition Classes
    ProcessNodeImpl → ProcessNode

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

    Definition Classes
    AnyRef

  17. def equals(a: Any): Boolean

    Definition Classes
    CompNode → Equals → AnyRef → Any

  18. def finalize(): Unit

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

  19. def firstChild[T]: T

    Definition Classes
    Attributable

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

    Definition Classes
    AnyRef → Any

  21. val gpk: KeyGrouping

  22. def hasCheckpoint: Boolean

    Definition Classes
    CompNode

  23. def hasChildren: Boolean

    Definition Classes
    Attributable

  24. def hashCode(): Int

    Definition Classes
    CompNode → AnyRef → Any

  25. val id: Int

    unique identifier for this computation node

    unique identifier for this computation node

    Definition Classes
    ProcessNodeImpl → CompNode

  26. val in: CompNode

  27. var index: Int

    Definition Classes
    Attributable

  28. def initTreeProperties(): Unit

    Definition Classes
    Attributable

  29. def isFirst: Boolean

    Definition Classes
    Attributable

  30. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  31. def isLast: Boolean

    Definition Classes
    Attributable

  32. def isRoot: Boolean

    Definition Classes
    Attributable

  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. val nodeSinks: Seq[Sink]

    list of additional sinks for this node

    list of additional sinks for this node

    Definition Classes
    GroupByKey → ProcessNodeImpl → ProcessNode

  38. def nodeSinksString: String

    display the sinks if any

    display the sinks if any

    Definition Classes
    ProcessNodeImpl

  39. final def notify(): Unit

    Definition Classes
    AnyRef

  40. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  41. def parent[T]: T

    Definition Classes
    Attributable

  42. var parent: Attributable

    Definition Classes
    Attributable

  43. def prev[T]: T

    Definition Classes
    Attributable

  44. var prev: Attributable

    Definition Classes
    Attributable

  45. lazy val sinks: Seq[Sink]

    returns

    all the additional sinks + the bridgeStore

    Definition Classes
    ProcessNodeImpl → CompNode

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

    Definition Classes
    AnyRef

  47. val toString: String

    Definition Classes
    GroupByKey → AnyRef → Any

  48. def updateSinks(f: (Seq[Sink]) ⇒ Seq[Sink]): GroupByKey

    Definition Classes
    GroupByKey → CompNode

  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
    GroupByKey → CompNode

  53. val wfk: WireReaderWriter

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