opções (DataStreamWriter)

Adiciona múltiplas opções de saída para a fonte de dados subjacente.

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

Sintaxe

options(**options)

Parâmetros

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

Devoluções

DataStreamWriter

Exemplos

Python

df = spark.readStream.format("rate").load()
df.writeStream.options(**{"k1": "v1", "k2": "v2"})
# <...streaming.readwriter.DataStreamWriter object ...>

Imprimir 3 linhas por lote sem truncamento:

Python

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