Grouping

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

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

final def !=(arg0: Any): Boolean

final def ##(): Int

def ***[L](q: Grouping[L]): Grouping[(K, L)]

Combine two groupings to a grouping of product type.

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def clone(): AnyRef

def contramap[L](f: (L) ⇒ K): Grouping[L]

Map on this grouping contravariantly.

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

final def getClass(): Class[_]

def groupOrder: Order[K]

Interface to scalaz.Order on groupCompare

def groupOrdering: Ordering[K]

Interface to scala.Ordering on groupCompare

def hashCode(): Int

def isGroupEqual(k1: K, k2: K): Boolean

Does group compare produce equal elements?

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

Does group compare produce the first greater than the second?

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

Does group compare produce the first less than the second?

final def isInstanceOf[T0]: Boolean

def isSortEqual(k1: K, k2: K): Boolean

Does sort compare produce equal elements?

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

Does sort compare produce the first greater than the second?

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

Does sort compare produce the first less than the second?

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def partition(key: K, num: Int): Int

Specifies how key-values are partitioned among Reducer tasks.

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

Construct grouping for secondary sort.

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

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

def sortOrder: Order[K]

Interface to scalaz.Order on sortCompare

def sortOrdering: Ordering[K]

Interface to scala.Ordering on sortCompare

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

def toString(): String

final def wait(): Unit

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

final def wait(arg0: Long): Unit

def zip[L](q: Grouping[L]): Grouping[(K, L)]

Combine two groupings to a grouping of product type.

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

Add two groupings together.