org.apache.spark

Class JavaFutureActionWrapper<S,T>

Object

org.apache.spark.JavaFutureActionWrapper<S,T>

All Implemented Interfaces:

java.util.concurrent.Future<T>, JavaFutureAction<T>

public class JavaFutureActionWrapper<S,T>
extends Object
implements JavaFutureAction<T>

Constructor Summary

Constructors

Constructor and Description
JavaFutureActionWrapper(FutureAction<S> futureAction, scala.Function1<S,T> converter)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning)
T	get()
T	get(long timeout, java.util.concurrent.TimeUnit unit)
boolean	isCancelled()
boolean	isDone()
java.util.List<Integer>	jobIds() Returns the job IDs run by the underlying async operation.

Methods inherited from class Object

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

Constructor Detail

JavaFutureActionWrapper

public JavaFutureActionWrapper(FutureAction<S> futureAction,
                       scala.Function1<S,T> converter)

Method Detail

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface java.util.concurrent.Future<T>

isDone

public boolean isDone()

Specified by:

isDone in interface java.util.concurrent.Future<T>

jobIds

public java.util.List<Integer> jobIds()

Description copied from interface: JavaFutureAction

Returns the job IDs run by the underlying async operation. This returns the current snapshot of the job list. Certain operations may run multiple jobs, so multiple calls to this method may return different lists.

Specified by:

jobIds in interface JavaFutureAction<T>

get

public T get()

Specified by:

get in interface java.util.concurrent.Future<T>

get

public T get(long timeout,
    java.util.concurrent.TimeUnit unit)

Specified by:

get in interface java.util.concurrent.Future<T>

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface java.util.concurrent.Future<T>