option (DataStreamReader)

Temel alınan veri kaynağı için bir giriş seçeneği ekler.

Kullanılabilir seçenekler için bkz. DataStreamReader seçenekleri.

Sözdizimi

option(key, value)

Parametreler

İadeler

DataStreamReader

Örnekler

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

Hız kaynağını kullanarak saniyede 10 satır oluşturun:

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