共 2 篇相关文章
双栈滑动窗口聚合用两个栈实现 O(1) 均摊的窗口插入、过期与查询,支持求和、计数、最值等任意结合律聚合,适用于实时监控与流式指标系统。
Databricks 为 Apache Spark Structured Streaming 推出按需状态重分区功能,可在不重建 Checkpoint、不丢失状态的前提下动态调整有状态流查询的分区数,解决扩展与成本难题。