processAllAvailable (StreamingQuery)

Blokuje, dokud nebudou všechna dostupná data ve zdroji zpracována a potvrzena do jímky. Určeno pro testování.

Syntaxe

processAllAvailable()

Návraty

None

Poznámky

V případě nepřetržitě přicházejících dat může tato metoda trvale blokovat. Tato metoda je zaručena pouze blokování, dokud data, která byla synchronně připojena ke zdroji datového proudu před vyvoláním (to znamená, getOffset že musí okamžitě odrážet přidání).

Příklady

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