需要面试准备
流处理服务收到按时间戳排好序的 (timestamp, value) 事件流,要把它聚合成会话窗口:一个会话是一段相邻间隔均 ≤ gap_seconds 的事件序列;第一个超过 gap_seconds 的间隔结束当前会话,下一条事件开启新会话。会话窗口是动态的——其长度完全由事件间隔决定,不像 tumbling/sliding 那样有固定网格。
(timestamp, value)
gap_seconds