नोट
इस पेज तक पहुँच के लिए प्रमाणन की आवश्यकता होती है. आप साइन इन करने या निर्देशिकाओं को बदलने का प्रयास कर सकते हैं.
इस पेज तक पहुँच के लिए प्रमाणन की आवश्यकता होती है. आप निर्देशिकाओं को बदलने का प्रयास कर सकते हैं.
Interface for saving the content of the streaming DataFrame out into external storage.
Returns
DataStreamWriter
Examples
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()