Packages

implicit class withCombineMethods[K, V] extends CombineMethods[K, V]

Linear Supertypes
CombineMethods[K, V], MethodExtensions[RDD[(K, V)]], Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. withCombineMethods
  2. CombineMethods
  3. MethodExtensions
  4. Serializable
  5. Serializable
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new withCombineMethods(self: RDD[(K, V)])(implicit arg0: ClassTag[K], arg1: ClassTag[V])

Value Members

  1. def combineValues[R](others: Traversable[RDD[(K, V)]], partitioner: Option[Partitioner])(f: (Iterable[V]) ⇒ R)(implicit arg0: ClassTag[R]): RDD[(K, R)]
    Definition Classes
    CombineMethods
  2. def combineValues[R](others: Traversable[RDD[(K, V)]])(f: (Iterable[V]) ⇒ R)(implicit arg0: ClassTag[R]): RDD[(K, R)]
    Definition Classes
    CombineMethods
  3. def combineValues[R](other: RDD[(K, V)], partitioner: Option[Partitioner])(f: (V, V) ⇒ R)(implicit arg0: ClassTag[R]): RDD[(K, R)]
    Definition Classes
    CombineMethods
  4. def combineValues[R](other: RDD[(K, V)])(f: (V, V) ⇒ R)(implicit arg0: ClassTag[R]): RDD[(K, R)]
    Definition Classes
    CombineMethods
  5. val self: RDD[(K, V)]
    Definition Classes
    withCombineMethods → MethodExtensions