StreamingQuery.AwaitTermination Method

Definition

Namespace:

Microsoft.Spark.Sql.Streaming

Assembly:

Microsoft.Spark.dll

Package:

Microsoft.Spark v1.0.0

Overloads

AwaitTermination()	Waits for the termination of this query, either by Stop() or by an exception.
AwaitTermination(Int64)	Returns true if this query is terminated within the timeout in milliseconds.

AwaitTermination()

Waits for the termination of this query, either by Stop() or by an exception.

public void AwaitTermination ();

member this.AwaitTermination : unit -> unit

Public Sub AwaitTermination ()

AwaitTermination(Int64)

Returns true if this query is terminated within the timeout in milliseconds.

public bool AwaitTermination (long timeoutMs);

member this.AwaitTermination : int64 -> bool

Public Function AwaitTermination (timeoutMs As Long) As Boolean

Parameters

timeoutMs

Int64

Timeout value in milliseconds

Returns

Boolean

true if this query is terminated within timeout

Remarks

If the query has terminated, then all subsequent calls to this method will either return true immediately (if the query was terminated by Stop()), or throw an exception immediately (if the query has terminated with an exception).