class ComplexFutureAction[T] extends FutureAction[T]
A FutureAction for actions that could trigger multiple Spark jobs. Examples include take, takeSample. Cancellation works by setting the cancelled flag to true and cancelling any pending jobs.
- Self Type
- ComplexFutureAction[T]
- Annotations
- @DeveloperApi()
- Source
- FutureAction.scala
- Alphabetic
- By Inheritance
- ComplexFutureAction
- FutureAction
- Future
- Awaitable
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new ComplexFutureAction(run: (JobSubmitter) ⇒ Future[T])
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
andThen[U](pf: PartialFunction[Try[T], U])(implicit executor: ExecutionContext): Future[T]
- Definition Classes
- Future
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
cancel(): Unit
Cancels the execution of this action.
Cancels the execution of this action.
- Definition Classes
- ComplexFutureAction → FutureAction
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
def
collect[S](pf: PartialFunction[T, S])(implicit executor: ExecutionContext): Future[S]
- Definition Classes
- Future
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
failed: Future[Throwable]
- Definition Classes
- Future
-
def
fallbackTo[U >: T](that: Future[U]): Future[U]
- Definition Classes
- Future
-
def
filter(p: (T) ⇒ Boolean)(implicit executor: ExecutionContext): Future[T]
- Definition Classes
- Future
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
flatMap[S](f: (T) ⇒ Future[S])(implicit executor: ExecutionContext): Future[S]
- Definition Classes
- Future
-
def
flatten[S](implicit ev: <:<[T, Future[S]]): Future[S]
- Definition Classes
- Future
-
def
foreach[U](f: (T) ⇒ U)(implicit executor: ExecutionContext): Unit
- Definition Classes
- Future
-
def
get(): T
Blocks and returns the result of this job.
Blocks and returns the result of this job.
- Definition Classes
- FutureAction
- Annotations
- @throws( classOf[SparkException] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
isCancelled: Boolean
Returns whether the action has been cancelled.
Returns whether the action has been cancelled.
- Definition Classes
- ComplexFutureAction → FutureAction
-
def
isCompleted: Boolean
Returns whether the action has already been completed with a value or an exception.
Returns whether the action has already been completed with a value or an exception.
- Definition Classes
- ComplexFutureAction → FutureAction → Future
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
jobIds: Seq[Int]
Returns the job IDs run by the underlying async operation.
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.
- Definition Classes
- ComplexFutureAction → FutureAction
-
def
map[S](f: (T) ⇒ S)(implicit executor: ExecutionContext): Future[S]
- Definition Classes
- Future
-
def
mapTo[S](implicit tag: ClassTag[S]): Future[S]
- Definition Classes
- Future
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
onComplete[U](func: (Try[T]) ⇒ U)(implicit executor: ExecutionContext): Unit
When this action is completed, either through an exception, or a value, applies the provided function.
When this action is completed, either through an exception, or a value, applies the provided function.
- Definition Classes
- ComplexFutureAction → FutureAction → Future
-
def
ready(atMost: Duration)(implicit permit: CanAwait): ComplexFutureAction.this.type
Blocks until this action completes.
Blocks until this action completes.
- atMost
maximum wait time, which may be negative (no waiting is done), Duration.Inf for unbounded waiting, or a finite positive duration
- returns
this FutureAction
- Definition Classes
- ComplexFutureAction → FutureAction → Awaitable
- Annotations
- @throws( classOf[InterruptedException] ) @throws( ... )
-
def
recover[U >: T](pf: PartialFunction[Throwable, U])(implicit executor: ExecutionContext): Future[U]
- Definition Classes
- Future
-
def
recoverWith[U >: T](pf: PartialFunction[Throwable, Future[U]])(implicit executor: ExecutionContext): Future[U]
- Definition Classes
- Future
-
def
result(atMost: Duration)(implicit permit: CanAwait): T
Awaits and returns the result (of type T) of this action.
Awaits and returns the result (of type T) of this action.
- atMost
maximum wait time, which may be negative (no waiting is done), Duration.Inf for unbounded waiting, or a finite positive duration
- returns
the result value if the action is completed within the specific maximum wait time
- Definition Classes
- ComplexFutureAction → FutureAction → Awaitable
- Annotations
- @throws( classOf[Exception] )
- Exceptions thrown
Exceptionexception during action execution
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
def
transform[S](f: (Try[T]) ⇒ Try[S])(implicit e: ExecutionContext): Future[S]
- Definition Classes
- ComplexFutureAction → Future
-
def
transform[S](s: (T) ⇒ S, f: (Throwable) ⇒ Throwable)(implicit executor: ExecutionContext): Future[S]
- Definition Classes
- Future
-
def
transformWith[S](f: (Try[T]) ⇒ Future[S])(implicit e: ExecutionContext): Future[S]
- Definition Classes
- ComplexFutureAction → Future
-
def
value: Option[Try[T]]
The value of this Future.
The value of this Future.
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.
- Definition Classes
- ComplexFutureAction → FutureAction → Future
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
withFilter(p: (T) ⇒ Boolean)(implicit executor: ExecutionContext): Future[T]
- Definition Classes
- Future
-
def
zip[U](that: Future[U]): Future[(T, U)]
- Definition Classes
- Future
-
def
zipWith[U, R](that: Future[U])(f: (T, U) ⇒ R)(implicit executor: ExecutionContext): Future[R]
- Definition Classes
- Future
Deprecated Value Members
-
def
onFailure[U](pf: PartialFunction[Throwable, U])(implicit executor: ExecutionContext): Unit
- Definition Classes
- Future
- Annotations
- @deprecated
- Deprecated
(Since version 2.12.0) use
onCompleteorfailed.foreachinstead (keep in mind that they take total rather than partial functions)
-
def
onSuccess[U](pf: PartialFunction[T, U])(implicit executor: ExecutionContext): Unit
- Definition Classes
- Future
- Annotations
- @deprecated
- Deprecated
(Since version 2.12.0) use
foreachoronCompleteinstead (keep in mind that they take total rather than partial functions)