processAllAvailable (StreamingQuery)

Memblokir hingga semua data yang tersedia di sumber telah diproses dan diterapkan ke sink. Ditujukan untuk pengujian.

Sintaksis

processAllAvailable()

Pengembalian Barang

None

Catatan

Dalam kasus data yang terus tiba, metode ini dapat memblokir selamanya. Metode ini hanya dijamin untuk memblokir sampai data yang telah ditambahkan secara sinkron ke sumber aliran sebelum pemanggilan (yaitu, getOffset harus segera mencerminkan penambahan).

Examples

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