public class AsyncRDDActions<T>
extends java.lang.Object
implements scala.Serializable
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<java.lang.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() |
protected static void |
initializeLogIfNecessary(boolean isInterpreter) |
protected static boolean |
isTraceEnabled() |
protected static org.slf4j.Logger |
log() |
protected static void |
logDebug(scala.Function0<java.lang.String> msg) |
protected static void |
logDebug(scala.Function0<java.lang.String> msg,
java.lang.Throwable throwable) |
protected static void |
logError(scala.Function0<java.lang.String> msg) |
protected static void |
logError(scala.Function0<java.lang.String> msg,
java.lang.Throwable throwable) |
protected static void |
logInfo(scala.Function0<java.lang.String> msg) |
protected static void |
logInfo(scala.Function0<java.lang.String> msg,
java.lang.Throwable throwable) |
protected static java.lang.String |
logName() |
protected static void |
logTrace(scala.Function0<java.lang.String> msg) |
protected static void |
logTrace(scala.Function0<java.lang.String> msg,
java.lang.Throwable throwable) |
protected static void |
logWarning(scala.Function0<java.lang.String> msg) |
protected static void |
logWarning(scala.Function0<java.lang.String> msg,
java.lang.Throwable throwable) |
FutureAction<scala.collection.Seq<T>> |
takeAsync(int num)
Returns a future for retrieving the first num elements of the RDD.
|
public static scala.concurrent.ExecutionContextExecutorService futureExecutionContext()
protected static java.lang.String logName()
protected static org.slf4j.Logger log()
protected static void logInfo(scala.Function0<java.lang.String> msg)
protected static void logDebug(scala.Function0<java.lang.String> msg)
protected static void logTrace(scala.Function0<java.lang.String> msg)
protected static void logWarning(scala.Function0<java.lang.String> msg)
protected static void logError(scala.Function0<java.lang.String> msg)
protected static void logInfo(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void logDebug(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void logTrace(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void logWarning(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void logError(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static boolean isTraceEnabled()
protected static void initializeLogIfNecessary(boolean isInterpreter)
public FutureAction<java.lang.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)