通过

StreamingQuery.ProcessAllAvailable 方法

  • 参考

定义

命名空间:
Microsoft.Spark.Sql.Streaming
程序集:
Microsoft.Spark.dll
包:
Microsoft.Spark v1.0.0

阻止，直到源中的所有可用数据都已处理并提交到接收器。 此方法用于测试。 请注意，在不断到达数据的情况下，此方法可能会永久阻止。 此外，此方法仅保证在调用之前已同步追加数据到 org.apache.spark.sql.execution.streaming.Source 的数据阻止。 (即 getOffset 必须立即反映添加) 。

public void ProcessAllAvailable ();
member this.ProcessAllAvailable : unit -> unit
Public Sub ProcessAllAvailable ()

适用于