opciones (DataStreamReader)

Agrega varias opciones de entrada para el origen de datos subyacente.

Para ver las opciones disponibles, consulte Opciones de DataStreamReader.

Sintaxis

options(**options)

Parámetros

Devoluciones

DataStreamReader

Ejemplos

spark.readStream.options(x="1", y=2)
# <...streaming.readwriter.DataStreamReader object ...>

Especifique las opciones como un diccionario:

spark.readStream.options(**{"k1": "v1", "k2": "v2"})
# <...streaming.readwriter.DataStreamReader object ...>

Genere 10 filas por segundo con 10 particiones mediante el origen de velocidad:

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