processAllAvailable (StreamingQuery)

Kaynaktaki tüm kullanılabilir veriler işlenip havuza işlenene kadar engeller. Test için tasarlanmıştır.

Sözdizimi

processAllAvailable()

İadeler

None

Notlar

Sürekli gelen veriler söz konusu olduğunda, bu yöntem sonsuza kadar engelleyebilir. Bu yöntemin yalnızca çağrıdan önce bir akış kaynağına zaman uyumlu olarak eklenene kadar engellemesi garanti edilir (yani, getOffset toplamayı hemen yansıtması gerekir).

Örnekler

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