Spark(55) -- StructuredStreaming -- Continuous Processing

 连续处理（Continuous Processing）是Spark 2.3中引入的一种新的实验性流执行模式，可实现低的（~1 ms）端到端延迟，并且至少具有一次容错保证。 将其与默认的微批处理（micro-batch processing）引擎相比较，该引擎可以实现一次性保证，但最多可实现~100ms的延迟。 1. 连续处理概述  连续处理（Continuous Processing）是“真正”

>>阅读原文<<