processAllAvailable (StreamingQuery)

Blokuje, dopóki wszystkie dostępne dane w źródle nie zostały przetworzone i zatwierdzone do ujścia. Przeznaczony do testowania.

Składnia

processAllAvailable()

Zwroty

None

Notatki

W przypadku ciągłego napływania danych ta metoda może blokować na zawsze. Ta metoda jest gwarantowana tylko do zablokowania danych, które zostały synchronicznie dołączone do źródła strumienia przed wywołaniem (oznacza to, getOffset że musi natychmiast odzwierciedlać dodanie).

Examples

sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
sq.processAllAvailable()
sq.stop()