public interface FutureAction<T>
extends scala.concurrent.Future<T>
Modifier and Type | Method and Description |
---|---|
void |
cancel()
Cancels the execution of this action.
|
T |
get()
Blocks and returns the result of this job.
|
boolean |
isCancelled()
Returns whether the action has been cancelled.
|
boolean |
isCompleted()
Returns whether the action has already been completed with a value or an exception.
|
scala.collection.Seq<Object> |
jobIds()
Returns the job IDs run by the underlying async operation.
|
<U> void |
onComplete(scala.Function1<scala.util.Try<T>,U> func,
scala.concurrent.ExecutionContext executor)
When this action is completed, either through an exception, or a value, applies the provided
function.
|
FutureAction<T> |
ready(scala.concurrent.duration.Duration atMost,
scala.concurrent.CanAwait permit)
Blocks until this action completes.
|
T |
result(scala.concurrent.duration.Duration atMost,
scala.concurrent.CanAwait permit)
Awaits and returns the result (of type T) of this action.
|
<S> scala.concurrent.Future<S> |
transform(scala.Function1<scala.util.Try<T>,scala.util.Try<S>> f,
scala.concurrent.ExecutionContext executor) |
<S> scala.concurrent.Future<S> |
transformWith(scala.Function1<scala.util.Try<T>,scala.concurrent.Future<S>> f,
scala.concurrent.ExecutionContext executor) |
scala.Option<scala.util.Try<T>> |
value()
The value of this Future.
|
void cancel()
FutureAction<T> ready(scala.concurrent.duration.Duration atMost, scala.concurrent.CanAwait permit)
ready
in interface scala.concurrent.Awaitable<T>
atMost
- maximum wait time, which may be negative (no waiting is done), Duration.Inf
for unbounded waiting, or a finite positive durationpermit
- (undocumented)T result(scala.concurrent.duration.Duration atMost, scala.concurrent.CanAwait permit) throws Exception
result
in interface scala.concurrent.Awaitable<T>
atMost
- maximum wait time, which may be negative (no waiting is done), Duration.Inf
for unbounded waiting, or a finite positive durationpermit
- (undocumented)Exception
- exception during action execution<U> void onComplete(scala.Function1<scala.util.Try<T>,U> func, scala.concurrent.ExecutionContext executor)
onComplete
in interface scala.concurrent.Future<T>
func
- (undocumented)executor
- (undocumented)boolean isCompleted()
isCompleted
in interface scala.concurrent.Future<T>
boolean isCancelled()
scala.Option<scala.util.Try<T>> value()
If the future is not completed the returned value will be None. If the future is completed the value will be Some(Success(t)) if it contains a valid result, or Some(Failure(error)) if it contains an exception.
value
in interface scala.concurrent.Future<T>
<S> scala.concurrent.Future<S> transform(scala.Function1<scala.util.Try<T>,scala.util.Try<S>> f, scala.concurrent.ExecutionContext executor)
<S> scala.concurrent.Future<S> transformWith(scala.Function1<scala.util.Try<T>,scala.concurrent.Future<S>> f, scala.concurrent.ExecutionContext executor)
T get() throws SparkException
SparkException
scala.collection.Seq<Object> jobIds()
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.