org.apache.spark.rdd

Class AsyncRDDActions<T>

Object

org.apache.spark.rdd.AsyncRDDActions<T>

All Implemented Interfaces:

java.io.Serializable

public class AsyncRDDActions<T>
extends Object
implements scala.Serializable

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

See Also:

Serialized Form

Constructor Summary

Constructors

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

Method Summary

Methods

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.

Methods inherited from class Object

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

Constructor Detail

AsyncRDDActions

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

Method Detail

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.Seq<T>> collectAsync()

Returns a future for retrieving all elements of this RDD.

Returns:

(undocumented)

takeAsync

public FutureAction<scala.collection.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)