觸發器。一旦模式建議

[User16783853906]

什麼時候推薦使用觸發器。一旦模式相比,固定與微批次處理的時間間隔?

[User16783853906]

觸發。一旦模式中,隻有一個微將執行批處理的最新數據和應用程序停止自己的一旦加工完成。這是有用的在這種情況下,你需要定期過程一切可用自上次處理過的數據。

前更多這方麵的信息,請參考https://spark.apache.org/docs/latest/structured-streaming-programming-guide.html觸發器

[User16869510359]

還要注意,像maxFilesPerTrigger配置,與Trigger.Once maxBytesPerTrigger被忽略。

流查詢,大大減少吞吐量可以切換觸發。曾經為了避免連續執行工作的檢查數據的可用性。