Condividi tramite

opzione (DataStreamWriter)

Aggiunge un'opzione di output per l'origine dati sottostante.

Sintassi

option(key, value)

Parametri

Parametro Tipo Descrizione
key str La chiave dell'opzione.
value str, int, float o bool Valore dell'opzione.

Restituzioni

DataStreamWriter

Examples

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

Stampare 3 righe per batch nella console:

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