trait ScioExecutionContext extends AnyRef
ScioExecutionContext is the result of ScioContext#run().
This is a handle to the underlying running job and allows getting the state, checking if it's completed and to wait for it's execution.
- Source
- ScioContext.scala
- Alphabetic
- By Inheritance
- ScioExecutionContext
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def awaitDuration: Duration
default await duration when using waitUntilFinish or waitUntilDone
- abstract def cancelJob: Boolean
default cancel job option when using waitUntilFinish or waitUntilDone
- abstract def isCompleted: Boolean
Whether the pipeline is completed.
- abstract def pipelineResult: PipelineResult
- abstract def state: State
Pipeline's current state.
- abstract def waitUntilDone(duration: Duration = awaitDuration, cancelJob: Boolean = cancelJob): ScioResult
Wait until the pipeline finishes with the State
DONE
(as opposed toCANCELLED
orFAILED
).Wait until the pipeline finishes with the State
DONE
(as opposed toCANCELLED
orFAILED
). Throw exception otherwise. - abstract def waitUntilFinish(duration: Duration = awaitDuration, cancelJob: Boolean = cancelJob): ScioResult
Wait until the pipeline finishes.
Wait until the pipeline finishes. If timeout duration is exceeded and
cancelJob
is set, cancel the internal PipelineResult.
Concrete 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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- 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()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- 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()