opção (DataStreamReader)

Adiciona uma opção de entrada para a fonte de dados subjacente.

Para opções disponíveis, consulte Opções do DataStreamReader.

Sintaxe

option(key, value)

Parâmetros

Parâmetro	Tipo	Descrição
key	str	A key Option.
value	str, int, float ou bool	O valor da opção.

Devoluções

DataStreamReader

Exemplos

Python

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

Gere 10 linhas por segundo usando a fonte de taxa:

Python

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