买专利卖专利找龙图腾，真高效！ 查专利查商标用IPTOP,全免费！专利年费监控用IP管家,真方便！

龙图腾网获悉北京科杰科技有限公司申请的专利一种基于FlinkSql的高效多源数据输出方法获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN120255863B 。

龙图腾网通过国家知识产权局官网在2025-09-16发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202510743850.9，技术领域涉及：G06F8/30；该发明授权一种基于FlinkSql的高效多源数据输出方法是由高海玲;高经郡;朱孟泽设计研发完成，并于2025-06-05向国家知识产权局提交的专利申请。

本一种基于FlinkSql的高效多源数据输出方法在说明书摘要公布了：本发明涉及多源数据输出技术领域，尤其涉及一种基于FlinkSql的高效多源数据输出方法，该方法基于不同的连接器表，编写若干个INSERTINTO语句，用于将处理后的数据插入相应的目标表；基于若干所述INSERTINTO语句的数据依赖倾向值或若干所述INSERTINTO语句的作业拓扑结构的复杂程度确定对若干所述INSERTINTO语句动态配置并行度或静态配置并行度；在对若干所述INSERTINTO语句动态配置并行度时，基于若干个INSERTINTO语句的数据冷热分布类型和或数据关联复杂程度确定初始并行度，并基于若干个INSERTINTO语句的数据新鲜容忍度和或实时数据延迟确定动态增大初始并行度或动态减小初始并行度，本发明通过提高对INSERTINTO语句分析的精准性进而精准配置并行度以提高输出效率。

本发明授权一种基于FlinkSql的高效多源数据输出方法在权利要求书中公布了：1.一种基于FlinkSql的高效多源数据输出方法，其特征在于，包括： 运用CREATETABLE语句创建多个不同的连接器表，每个连接器表对应一个数据源或者目标，同时确定数据的格式、存储位置以及连接信息； 使用SELECT语句编写业务逻辑，对输入数据进行查询、转换和聚合操作； 基于不同的连接器表，编写若干个INSERTINTO语句，用于将SELECT语句处理后的数据插入相应的目标表； 基于若干所述INSERTINTO语句的数据依赖倾向值或若干所述INSERTINTO语句的作业拓扑结构的复杂程度确定对若干所述INSERTINTO语句动态配置并行度； 在对若干所述INSERTINTO语句动态配置并行度时，基于若干个INSERTINTO语句的数据冷热分布类型和或数据关联复杂程度确定初始并行度，并基于若干个INSERTINTO语句的数据新鲜容忍度和或实时数据延迟确定动态增大初始并行度或动态减小初始并行度； 实时监测每个INSERTINTO语句对应的任务进度，并基于处理任务执行偏差程度与预设偏差程度，或资源弹性值是否出现波动的判定结果，针对动态配置并行度的判断参数进行调整； 若干所述INSERTINTO语句的数据依赖倾向值根据若干个INSERTINTO语句中存在强依赖关系的INSERTINTO语句数量与若干个INSERTINTO语句总数量的比值确定； 所述数据新鲜容忍度根据数据更新频率确定。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人北京科杰科技有限公司，其通讯地址为：100089 北京市海淀区东升科技园北街6号院10号楼11层101；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。