Not
Bu sayfaya erişim yetkilendirme gerektiriyor. Oturum açmayı veya dizinleri değiştirmeyi deneyebilirsiniz.
Bu sayfaya erişim yetkilendirme gerektiriyor. Dizinleri değiştirmeyi deneyebilirsiniz.
Temel alınan veri kaynağı için bir çıkış seçeneği ekler.
Kullanılabilir seçenekler için bkz . DataStreamWriter seçenekleri.
Sözdizimi
option(key, value)
Parametreler
| Parametre | Türü | Açıklama |
|---|---|---|
key |
str | Seçenek tuşu. |
value |
str, int, float veya bool | Seçenek değeri. |
İadeler
DataStreamWriter
Örnekler
df = spark.readStream.format("rate").load()
df.writeStream.option("x", 1)
# <...streaming.readwriter.DataStreamWriter object ...>
Konsola toplu iş başına 3 satır yazdırın:
import time
q = spark.readStream.format(
"rate").option("rowsPerSecond", 10).load().writeStream.format(
"console").option("numRows", 3).start()
time.sleep(3)
q.stop()