opsi (DataStreamReader)

Menambahkan beberapa opsi input untuk sumber data yang mendasar.

Sintaksis

options(**options)

Parameter-parameternya

Parameter	Tipe	Deskripsi
**options	kamus	Pasangan kunci-nilai opsi.

Pengembalian Barang

DataStreamReader

Examples

spark.readStream.options(x="1", y=2)
# <...streaming.readwriter.DataStreamReader object ...>

Tentukan opsi sebagai kamus:

spark.readStream.options(**{"k1": "v1", "k2": "v2"})
# <...streaming.readwriter.DataStreamReader object ...>

Hasilkan 10 baris per detik dengan 10 partisi menggunakan sumber Laju:

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