writeStream
ストリーミングDataFrameのコンテンツを外部ストレージに保存するためのインターフェース。
戻り値
DataStreamWriter
例
Python
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()