processAllAvailable (StreamingQuery)

Blocca fino a quando non vengono elaborati tutti i dati disponibili nell'origine ed è stato eseguito il commit nel sink. Destinato ai test.

Sintassi

processAllAvailable()

Restituzioni

None

Note

Nel caso di dati in arrivo continuamente, questo metodo può bloccarsi per sempre. Questo metodo è garantito solo per bloccare fino a quando i dati che sono stati accodati in modo sincrono a un'origine di flusso prima della chiamata , getOffset ovvero devono riflettere immediatamente l'aggiunta.

Examples

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