Package org.apache.spark.rdd

Class AsyncRDDActions<T>

Object
org.apache.spark.rdd.AsyncRDDActions<T>
All Implemented Interfaces:
Serializable, org.apache.spark.internal.Logging
public class AsyncRDDActions<T> extends Object implements Serializable, org.apache.spark.internal.Logging
A set of asynchronous RDD actions available through an implicit conversion.
See Also:

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.spark.internal.Logging

    org.apache.spark.internal.Logging.LogStringContext, org.apache.spark.internal.Logging.SparkShellLoggingFilter

  • Constructor Summary

    Constructors
    Constructor
    Description
    AsyncRDDActions(RDD<T> self, scala.reflect.ClassTag<T> evidence$1)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    FutureAction<scala.collection.immutable.Seq<T>>
    collectAsync()
    Returns a future for retrieving all elements of this RDD.
    FutureAction<Object>
    countAsync()
    Returns a future for counting the number of elements in the RDD.
    FutureAction<scala.runtime.BoxedUnit>
    foreachAsync(scala.Function1<T,scala.runtime.BoxedUnit> f)
    Applies a function f to all elements of this RDD.
    FutureAction<scala.runtime.BoxedUnit>
    foreachPartitionAsync(scala.Function1<scala.collection.Iterator<T>,scala.runtime.BoxedUnit> f)
    Applies a function f to each partition of this RDD.
    static scala.concurrent.ExecutionContextExecutorService
    futureExecutionContext()
     
    FutureAction<scala.collection.immutable.Seq<T>>
    takeAsync(int num)
    Returns a future for retrieving the first num elements of the RDD.

    Methods inherited from class java.lang.Object

    equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.apache.spark.internal.Logging

    initializeForcefully, initializeLogIfNecessary, initializeLogIfNecessary, initializeLogIfNecessary$default$2, isTraceEnabled, log, logBasedOnLevel, logDebug, logDebug, logDebug, logDebug, logError, logError, logError, logError, logInfo, logInfo, logInfo, logInfo, logName, LogStringContext, logTrace, logTrace, logTrace, logTrace, logWarning, logWarning, logWarning, logWarning, MDC, org$apache$spark$internal$Logging$$log_, org$apache$spark$internal$Logging$$log__$eq, withLogContext

  • Constructor Details

    • AsyncRDDActions

      public AsyncRDDActions(RDD<T> self, scala.reflect.ClassTag<T> evidence$1)

  • Method Details

    • futureExecutionContext

      public static scala.concurrent.ExecutionContextExecutorService futureExecutionContext()

    • countAsync

      public FutureAction<Object> countAsync()
      Returns a future for counting the number of elements in the RDD.
      Returns:
      (undocumented)

    • collectAsync

      public FutureAction<scala.collection.immutable.Seq<T>> collectAsync()
      Returns a future for retrieving all elements of this RDD.
      Returns:
      (undocumented)

    • takeAsync

      public FutureAction<scala.collection.immutable.Seq<T>> takeAsync(int num)
      Returns a future for retrieving the first num elements of the RDD.
      Parameters:
      num - (undocumented)
      Returns:
      (undocumented)

    • foreachAsync

      public FutureAction<scala.runtime.BoxedUnit> foreachAsync(scala.Function1<T,scala.runtime.BoxedUnit> f)
      Applies a function f to all elements of this RDD.
      Parameters:
      f - (undocumented)
      Returns:
      (undocumented)

    • foreachPartitionAsync

      public FutureAction<scala.runtime.BoxedUnit> foreachPartitionAsync(scala.Function1<scala.collection.Iterator<T>,scala.runtime.BoxedUnit> f)
      Applies a function f to each partition of this RDD.
      Parameters:
      f - (undocumented)
      Returns:
      (undocumented)