流式特征计算

流式特征计算通常依托流处理引擎（如Flink、Spark Structured Streaming或Kafka Streams）实现，其核心是把特征定义为对无界事件流的持续聚合。

流式特征计算工程上需要处理乱序事件（借助水位线watermark机制）、状态存储与恢复（checkpoint）、以及窗口结果与在线模型推理之间的低延迟衔接。