FlinkSQL实时批量数据融合方法