writeStream

스트리밍 콘텐츠를 외부 스토리지에 저장하기 DataFrame 위한 인터페이스입니다.

Returns

DataStreamWriter

예제

import time
import tempfile
df = spark.readStream.format("rate").load()
type(df.writeStream)
# <class '...streaming.readwriter.DataStreamWriter'>

with tempfile.TemporaryDirectory(prefix="writeStream") as d:
    query = df.writeStream.toTable("my_table", checkpointLocation=d)
    time.sleep(3)
    query.stop()