readStream

Zwraca element DataStreamReader , który może służyć do odczytywania strumieni danych jako przesyłania strumieniowego DataFrame.

Składnia

readStream

Zwroty

DataStreamReader

Examples

import time

# Use Rate source that generates rows continuously, apply modulo by 3,
# then write the stream to the console. The streaming query stops in 3 seconds.
df = spark.readStream.format("rate").load()
df = df.selectExpr("value % 3 as v")
q = df.writeStream.format("console").start()
time.sleep(3)
q.stop()