opções (DataStreamReader)

Adiciona múltiplas opções de entrada para a fonte de dados subjacente.

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

Sintaxe

options(**options)

Parâmetros

Parâmetro	Tipo	Descrição
**options	dicionário	par chave-valor de opções.

Devoluções

DataStreamReader

Exemplos

Python

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

Especifique as opções como um dicionário:

Python

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

Gere 10 linhas por segundo com 10 partições usando a fonte de taxa:

Python

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