StreamingQuery.ProcessAllAvailable 方法

參考

定義

命名空間:: Microsoft.Spark.Sql.Streaming

組件:: Microsoft.Spark.dll

套件:: Microsoft.Spark v1.0.0

重要

部分資訊涉及發行前產品，在發行之前可能會有大幅修改。 Microsoft 對此處提供的資訊，不做任何明確或隱含的瑕疵擔保。

封鎖，直到來源中的所有可用資料都已處理並認可至接收為止。這個方法適用于測試。請注意，在持續抵達資料的情況下，這個方法可能會永久封鎖。此外，這個方法只會保證會封鎖，直到在叫用之前同步附加資料的資料 org.apache.spark.sql.execution.streaming.Source 為止。 (亦即 getOffset 必須立即反映加法) 。

public void ProcessAllAvailable();

member this.ProcessAllAvailable : unit -> unit

Public Sub ProcessAllAvailable ()

適用於