opsi (DataStreamReader)

Menambahkan opsi input untuk sumber data yang mendasar.

Sintaksis

option(key, value)

Parameter-parameternya

Parameter	Tipe	Deskripsi
key	str	Kunci opsi.
value	str, int, float, atau bool	Nilai opsi.

Pengembalian Barang

DataStreamReader

Examples

spark.readStream.option("x", 1)
# <...streaming.readwriter.DataStreamReader object ...>

Hasilkan 10 baris per detik menggunakan sumber Laju:

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