option (DataStreamReader)

Hozzáad egy bemeneti beállítást az alapul szolgáló adatforráshoz.

A rendelkezésre álló lehetőségekért tekintse meg a DataStreamReader beállításait.

Szemantika

option(key, value)

Paraméterek

Paraméter	Típus	Leírás
key	str	A beállításkulcs.
value	str, int, float vagy bool	A beállítás értéke.

Visszatérítések

DataStreamReader

Examples

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

Másodpercenként 10 sort generálhat a Sebesség forrás használatával:

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