一种基于流特征感知动态窗口与状态补偿的实时数据治理方法

本发明提供了一种基于流特征感知动态窗口与状态补偿的实时数据治理方法，包括获取流数据；根据运行状态参数通过自适应控制算法动态调整数据质量评估计算窗口的窗口边界；在窗口内执行非阻塞质量评估并生成窗口污染标记；根据标记将被污染窗口的数据重定向至隔离沙盒，未被污染的数据继续流转；针对已流入下游的异常数据构造反向补偿流注入流水线，下游聚合算子据此对键控状态执行状态逆运算，擦除异常数据造成的状态污染。本发明可以提升流数据治理的实时性、准确性与系统稳定性。