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
- Protected
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(reason: Option[String]): Unit
Cancels the execution of this action with an optional reason.
Cancels the execution of this action with an optional reason.
- Definition Classes
- ComplexFutureAction → FutureAction
- def cancel(): Unit
Cancels the execution of this action.
Cancels the execution of this action.
- Definition Classes
- FutureAction
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @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: AnyRef): 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 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[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @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
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @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(classOf[scala.concurrent.TimeoutException])
- 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(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- 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 finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)