alternativet (DataStreamReader)

Lägger till ett indataalternativ för den underliggande datakällan.

Syntax

option(key, value)

Parameters

Parameter	Type	Beskrivning
key	str	Alternativnyckeln.
value	str, int, float eller bool	Alternativvärdet.

Retur

DataStreamReader

Exempel

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

Generera 10 rader per sekund med hjälp av ratekällan:

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