StreamingQuery.ProcessAllAvailable Method
Definition
Important
Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.
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 -> unitPublic Sub ProcessAllAvailable ()