Packages

c

org.apache.spark.rdd

AsyncRDDActions

class AsyncRDDActions[T] extends Serializable with Logging

A set of asynchronous RDD actions available through an implicit conversion.

Source
AsyncRDDActions.scala
Linear Supertypes
Logging, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AsyncRDDActions
  2. Logging
  3. Serializable
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new AsyncRDDActions(self: RDD[T])(implicit arg0: ClassTag[T])

Type Members

  1. implicit class LogStringContext extends AnyRef
    Definition Classes
    Logging

Value Members

  1. def collectAsync(): FutureAction[Seq[T]]

    Returns a future for retrieving all elements of this RDD.

  2. def countAsync(): FutureAction[Long]

    Returns a future for counting the number of elements in the RDD.

  3. def foreachAsync(f: (T) => Unit): FutureAction[Unit]

    Applies a function f to all elements of this RDD.

  4. def foreachPartitionAsync(f: (Iterator[T]) => Unit): FutureAction[Unit]

    Applies a function f to each partition of this RDD.

  5. def takeAsync(num: Int): FutureAction[Seq[T]]

    Returns a future for retrieving the first num elements of the RDD.