迟到数据策略决定如何修正已有计算结果：数据管道通过多个步骤完成采集与转换

数据管道通过多个步骤完成采集与转换。抽取转换加载先加工再写入目标存储。抽取加载转换先保留数据再执行加工。数据湖保存多种结构和格式的原始数据。数据仓库面向分析组织较稳定的数据模型。湖仓方案尝试结合开放存储与表管理能力。列式存储适合读取少量列的大规模分析。行式存储适合部分面向完整记录的访问。

数据工程组织数据的获取与加工和交付。数据源可能来自业务系统或外部采集。批处理按照时间或数据规模集中执行任务。流处理持续处理不断到达的数据事件。事件时间对应现实业务事件发生的时刻。处理时间对应系统实际执行计算的时刻。乱序事件可能晚于其业务发生顺序到达。水位线用于表达事件时间处理的进展估计。

迟到数据策略决定如何修正已有计算结果。窗口把连续流划分为可计算的数据范围。滚动窗口按照固定边界连续划分时间。滑动窗口允许相邻时间范围部分重叠。会话窗口根据活动间隔识别交互片段。状态管理保存跨事件计算需要的中间信息。检查点帮助流处理任务在故障后恢复。端到端一致性还需要数据源和输出端配合。