Nota
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare ad accedere o modificare le directory.
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare a modificare le directory.
Aggiunge un'opzione di input per l'origine dati sottostante.
Per le opzioni disponibili, vedere Opzioni dataStreamReader.
Sintassi
option(key, value)
Parametri
| Parametro | Tipo | Descrizione |
|---|---|---|
key |
str | La chiave dell'opzione. |
value |
str, int, float o bool | Valore dell'opzione. |
Restituzioni
DataStreamReader
Examples
spark.readStream.option("x", 1)
# <...streaming.readwriter.DataStreamReader object ...>
Generare 10 righe al secondo usando l'origine Frequenza:
import time
q = spark.readStream.format(
"rate").option("rowsPerSecond", 10).load().writeStream.format("console").start()
time.sleep(3)
q.stop()