MillWheel: Fault-Tolerant Stream Processing at Internet Scale

为什么要做MillWheel？ 因为当前的其他的流式系统，无法同时满足 fault tolerance, versatility, and scalability 的需求。 Spark Streaming [34] and Sonora [32] do excellent jobs of efficient checkpointing, but limit the space of operato

>>阅读原文<<