processAllAvailable (StreamingQuery)

Блокирует до тех пор, пока все доступные данные в источнике не будут обработаны и зафиксированы в приемнике. Предназначено для тестирования.

Синтаксис

processAllAvailable()

Возвраты

None

Примечания

В случае постоянного прибытия данных этот метод может блокироваться навсегда. Этот метод гарантированно блокируется только до тех пор, getOffset пока данные, которые были синхронно добавлены к источнику потока до вызова (т. е. должны немедленно отражать добавление).

Примеры

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