com.nicta.scoobi.core

Grouping

Related Docs: object Grouping | package core

trait Grouping[K] extends KeyGrouping

Specify the way in which key-values are "shuffled". Used by groupByKey in DList

Annotations
@implicitNotFound( ... )
Linear Supertypes
KeyGrouping, AnyRef, Any
Known Subclasses
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Grouping
  2. KeyGrouping
  3. AnyRef
  4. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Abstract Value Members

  1. abstract def groupCompare(x: K, y: K): Ordering

    Specifies how values, for a given partition, are grouped together in a given partition.

Concrete Value Members

  1. final def !=(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Definition Classes
    AnyRef → Any
  3. def ***[L](q: Grouping[L]): Grouping[(K, L)]

    Combine two groupings to a grouping of product type.

    Combine two groupings to a grouping of product type. Alias for zip

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

    Definition Classes
    AnyRef → Any
  5. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  6. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  7. def contramap[L](f: (L) ⇒ K): Grouping[L]

    Map on this grouping contravariantly.

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

    Definition Classes
    AnyRef
  9. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  10. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  11. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  12. def groupOrder: Order[K]

    Interface to scalaz.Order on groupCompare

  13. def groupOrdering: Ordering[K]

    Interface to scala.Ordering on groupCompare

  14. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  15. def isGroupEqual(k1: K, k2: K): Boolean

    Does group compare produce equal elements?

  16. def isGroupGreaterThan(k1: K, k2: K): Boolean

    Does group compare produce the first greater than the second?

  17. def isGroupLessThan(k1: K, k2: K): Boolean

    Does group compare produce the first less than the second?

  18. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  19. def isSortEqual(k1: K, k2: K): Boolean

    Does sort compare produce equal elements?

  20. def isSortGreaterThan(k1: K, k2: K): Boolean

    Does sort compare produce the first greater than the second?

  21. def isSortLessThan(k1: K, k2: K): Boolean

    Does sort compare produce the first less than the second?

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

    Definition Classes
    AnyRef
  23. final def notify(): Unit

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

    Definition Classes
    AnyRef
  25. def partition(key: K, num: Int): Int

    Specifies how key-values are partitioned among Reducer tasks.

  26. def secondarySort[L](q: Grouping[L]): Grouping[(K, L)]

    Construct grouping for secondary sort.

  27. def sortCompare(x: K, y: K): Ordering

    Specifies the order in which grouped values are presented to a Reducer task, for a given partition.

  28. def sortOrder: Order[K]

    Interface to scalaz.Order on sortCompare

  29. def sortOrdering: Ordering[K]

    Interface to scala.Ordering on sortCompare

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

    Definition Classes
    AnyRef
  31. def toString(): String

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

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  35. def zip[L](q: Grouping[L]): Grouping[(K, L)]

    Combine two groupings to a grouping of product type.

    Combine two groupings to a grouping of product type. Alias for ***

  36. def |+|(q: Grouping[K]): Grouping[K]

    Add two groupings together.

Inherited from KeyGrouping

Inherited from AnyRef

Inherited from Any

Ungrouped