0-structuredStreaming-base

Structured Streaming 在spark sql 引擎基礎上建立的可擴展,容錯的流處理引擎。 可以以處理一小批靜態數據的方式處理流計算 當流數據到來時,spark sql 引擎會連續的增量的更新最終結果,spark sql 的所有優化都用使用到 通過checkpointing and Write Ahead Logs 保證端到端的 exactly-once 容錯處理 fast, sc
本站公眾號
   歡迎關注本站公眾號,獲取更多信息