processAllAvailable (StreamingQuery)

Bloquea hasta que todos los datos disponibles del origen se hayan procesado y confirmado en el receptor. Está destinado para las pruebas.

Sintaxis

processAllAvailable()

Devoluciones

None

Notas

En el caso de datos que llegan continuamente, este método puede bloquearse para siempre. Este método solo se garantiza que se bloquee hasta que los datos que se hayan anexado de forma sincrónica a un origen de flujo antes de la invocación (es decir, getOffset deben reflejar inmediatamente la adición).

Ejemplos

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