02-10-2023上午09:43
我有一個連續流運行工作,我想停止這種在周末和周一重新開始。這是我流的工作代碼。
(spark.readStream.format(“δ”).load (input_path)
.writeStream
input_checkpoint_path .option (“checkpointLocation”)
.trigger (processingTime = 1分鍾)
.foreachBatch (foreachBatchFunction)
.start ()
)
問候
桑傑
02-10-2023十一17點
嗨@Sanjay耆那教的,你可以停止你的工作從UI
02-11-202302:07我
謝謝你Lakshay。我想通過一些正則表達式或編程自動停止。
其困難和遺忘的機會停止每個周五和周一重新開始。
02-10-2023下午08:42
我們將“連續”工作作為一個一流的公民對於這個場景。所以你將能夠“暫停”工作例如,周五下午和周一重新開始。跟你的磚客戶服務團隊訪問私人預覽。
謝謝你馬修。我將檢查連續工作特性。
從未顯出
加入我們的快速增長的數據專業人員和專家的80 k +社區成員,準備發現,幫助和合作而做出有意義的聯係。
點擊在這裏注冊今天,加入!
參與令人興奮的技術討論,加入一個組與你的同事和滿足我們的成員。