public class AsyncRDDActions<T>
extends Object
implements scala.Serializable, org.apache.spark.internal.Logging
| Constructor and Description |
|---|
AsyncRDDActions(RDD<T> self,
scala.reflect.ClassTag<T> evidence$1) |
| Modifier and Type | Method and Description |
|---|---|
FutureAction<scala.collection.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.Seq<T>> |
takeAsync(int num)
Returns a future for retrieving the first num elements of the RDD.
|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait$init$, initializeForcefully, initializeLogIfNecessary, initializeLogIfNecessary, initializeLogIfNecessary$default$2, initLock, isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning, org$apache$spark$internal$Logging$$log__$eq, org$apache$spark$internal$Logging$$log_, uninitializepublic static scala.concurrent.ExecutionContextExecutorService futureExecutionContext()
public FutureAction<Object> countAsync()
public FutureAction<scala.collection.Seq<T>> collectAsync()
public FutureAction<scala.collection.Seq<T>> takeAsync(int num)
num - (undocumented)public FutureAction<scala.runtime.BoxedUnit> foreachAsync(scala.Function1<T,scala.runtime.BoxedUnit> f)
f - (undocumented)public FutureAction<scala.runtime.BoxedUnit> foreachPartitionAsync(scala.Function1<scala.collection.Iterator<T>,scala.runtime.BoxedUnit> f)
f - (undocumented)