取消
顯示的結果
而不是尋找
你的意思是:

當我應該使用“.start ()”writeStream嗎?

麥當娜
重視貢獻二世

你好,

我練習與磚。在樣本的筆記本,我看到不同的使用writeStream有或沒有“.start()方法。樣品如下:

沒有.start ()

火花。readStream .format .option (“cloudFiles (“cloudFiles”)。格式”,source_format) .option (“cloudFiles。schemaLocation”, checkpoint_directory) .load (data_source) .writeStream .option (“checkpointLocation”, checkpoint_directory) .option (“mergeSchema”、“true”) .table (table_name)

用.start ()

(myDF .writeStream .format .option(“δ”)(“checkpointLocation”, checkpointPath) .outputMode(“追加”).start(路徑))

用.start ()

查詢= (streaming_df。writeStream .foreachBatch (streaming_merge.upsert_to_delta) .outputMode .option(“更新”)(“checkpointLocation”, f“{DA.paths.checkpoints} /錄音”).trigger (availableNow = True) .start ()) query.awaitTermination ()

1)我不明白應該/不應該用“.start()方法。我很感激如果你能指導我。

2)如果我不通過“路徑”到“開始”(),數據文件會寫嗎?

謝謝你的幫助。

2回答2

匿名
不適用

嗨@Mohammad軍刀

很高興認識你,謝謝你的問題!

看看你的同行在社區中有一個回答你的問題。否則bricksters能早日回到你身邊。

謝謝

麥當娜
重視貢獻二世

謝謝你的消息。我仍然在尋找答案。

歡迎來到磚社區:讓學習、網絡和一起慶祝

加入我們的快速增長的數據專業人員和專家的80 k +社區成員,準備發現,幫助和合作而做出有意義的聯係。

點擊在這裏注冊今天,加入!

參與令人興奮的技術討論,加入一個組與你的同事和滿足我們的成員。

Baidu
map