option (DataStreamReader)

Agrega una opción de entrada para el origen de datos subyacente.

Para ver las opciones disponibles, consulte Opciones de DataStreamReader.

Sintaxis

option(key, value)

Parámetros

Devoluciones

DataStreamReader

Ejemplos

spark.readStream.option("x", 1)
# <...streaming.readwriter.DataStreamReader object ...>

Genere 10 filas por segundo mediante el origen de velocidad:

import time
q = spark.readStream.format(
    "rate").option("rowsPerSecond", 10).load().writeStream.format("console").start()
time.sleep(3)
q.stop()