Skip to content

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:

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: