StreamingQuery.ProcessAllAvailable Method

Definition

Namespace:

Microsoft.Spark.Sql.Streaming

Assembly:

Microsoft.Spark.dll

Package:

Microsoft.Spark v1.0.0

Blocks until all available data in the source has been processed and committed to the sink. This method is intended for testing. Note that in the case of continually arriving data, this method may block forever. Additionally, this method is only guaranteed to block until data that has been synchronously appended data to a org.apache.spark.sql.execution.streaming.Source prior to invocation. (i.e. getOffset must immediately reflect the addition).

public void ProcessAllAvailable ();

member this.ProcessAllAvailable : unit -> unit

Public Sub ProcessAllAvailable ()