FlowExecution¶
FlowExecution
is an abstraction of flow executions (batch or streaming).
FlowExecution
can be executed asynchronously.
Contract¶
TableIdentifier¶
identifier: TableIdentifier
Destination¶
destination: Output
QueryOrigin¶
getOrigin: QueryOrigin
isStreaming¶
isStreaming: Boolean
PipelineUpdateContext¶
updateContext: PipelineUpdateContext
PipelineUpdateContext of this flow execution
executeInternal¶
executeInternal(): Future[Unit]
See:
Used when:
FlowExecution
is requested to execute asynchronously
Implementations¶
Execute Asynchronously¶
executeAsync(): Unit
executeAsync
uses the internal _future to control whether this flow has been executed or not.
executeAsync
executeInternal (and stores the result of this execution in the internal _future).
Final Method
executeAsync
is a Scala final method and may not be overridden in subclasses.
Learn more in the Scala Language Specification.
executeAsync
is used when:
GraphExecution
is requested to planAndStartFlow