3.3.2 窗口触发器与失效器

文档摘要

3.3.2 窗口触发器与失效器在流式计算的世界里，窗口不是玻璃，而是时间的刻度尺；触发器不是开关，而是数据洪流中一次精准的“叩门”；失效器也不是断电保护，而是对历史承诺的一次庄严清算。当你在 Flink、Spark Streaming 或 Kafka Streams 中写下这一行代码时，你真正签下的，是一份关于何时计算、为何计算、以及何时作废计算结果的三重契约——而这份契约的执行引擎，正是本节要剖开肌理、逐行解构的：窗口触发器（Trigger）与失效器（Purging & Eviction）。这不是概念罗列，也不是 API 文档的复述。这是一场深入运行时内核的手术：我们要拨开的表层语义，直抵其背后状态机跃迁的判定条件；