opção (DataStreamWriter)

Adiciona uma opção de saída para a fonte de dados subjacente.

Sintaxe

option(key, value)

Parâmetros

Parâmetro Tipo Descrição
key str A tecla de opção.
value força, inteligência, flutuação ou bool O valor da opção.

Devoluções

DataStreamWriter

Exemplos

df = spark.readStream.format("rate").load()
df.writeStream.option("x", 1)
# <...streaming.readwriter.DataStreamWriter object ...>

Imprime 3 linhas por lote na consola:

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