option (DataStreamReader)

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

Sintaxis

option(key, value)

Parámetros

Parámetro	Tipo	Descripción
key	str	Tecla de opción.
value	str, int, float o bool	Valor de opción.

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()