StreamingQuery.ProcessAllAvailable Metoda

Reference

Definice

Obor názvů:: Microsoft.Spark.Sql.Streaming

Sestavení:: Microsoft.Spark.dll

Balíček:: Microsoft.Spark v1.0.0

Důležité

Některé informace platí pro předběžně vydaný produkt, který se může zásadně změnit, než ho výrobce nebo autor vydá. Microsoft neposkytuje žádné záruky, výslovné ani předpokládané, týkající se zde uváděných informací.

Blokuje, dokud nebudou všechna dostupná data ve zdroji zpracována a potvrzena do jímky. Tato metoda je určená pro testování. Upozorňujeme, že v případě nepřetržitě přicházejících dat může tato metoda trvale blokovat. Kromě toho je tato metoda garantována pouze blokování, dokud data, která byla synchronně připojena data před org.apache.spark.sql.execution.streaming.Source vyvoláním. (tj. getOffset musí okamžitě odrážet sčítání).

public void ProcessAllAvailable();

member this.ProcessAllAvailable : unit -> unit

Public Sub ProcessAllAvailable ()

Platí pro