Spark(55) -- StructuredStreaming -- Continuous Processing

 連續處理（Continuous Processing）是Spark 2.3中引入的一種新的實驗性流執行模式，可實現低的（~1 ms）端到端延遲，並且至少具有一次容錯保證。 將其與默認的微批處理（micro-batch processing）引擎相比較，該引擎可以實現一次性保證，但最多可實現~100ms的延遲。 1. 連續處理概述  連續處理（Continuous Processing）是「真正」

>>阅读原文<<