0-structuredStreaming-base

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

>>阅读原文<<