如何构建批流一体数据融合平台的一致性语义保证？