Document
拖动滑块完成拼图
个人中心

预订订单
服务订单
发布专利 发布成果 人才入驻 发布商标 发布需求

请提出您的宝贵建议,有机会获取IP积分或其他奖励

投诉建议

在线咨询

联系我们

龙图腾公众号
首页 专利交易 IP管家助手 科技果 科技人才 科技服务 国际服务 商标交易 会员权益 需求市场 关于龙图腾
 /  免费注册
到顶部 到底部
清空 搜索
当前位置 : 首页 > 专利喜报 > 浪潮云信息技术股份公司董可伦获国家专利权

浪潮云信息技术股份公司董可伦获国家专利权

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

龙图腾网获悉浪潮云信息技术股份公司申请的专利一种基于Spark实现Hudi数据跨集群迁移的方法及工具获国家发明授权专利权,本发明授权专利权由国家知识产权局授予,授权公告号为:CN115438022B

龙图腾网通过国家知识产权局官网在2025-09-26发布的发明授权授权公告中获悉:该发明授权的专利申请号/专利号为:202210967959.7,技术领域涉及:G06F16/21;该发明授权一种基于Spark实现Hudi数据跨集群迁移的方法及工具是由董可伦;周永进;李国涛设计研发完成,并于2022-08-12向国家知识产权局提交的专利申请。

一种基于Spark实现Hudi数据跨集群迁移的方法及工具在说明书摘要公布了:本发明公开一种基于Spark实现Hudi数据跨集群迁移的方法,涉及数据迁移技术领域,包括:利用HiveSQL在目标集群下创建数据库,该数据库与源集群的名称和路径相同;利用Hadoop和Linux的命令,将源集群HDFS上的Hudi表数据文件上传到目标集群对应HDFS路径上的数据库中;解析表的配置参数,HiveSyncTool根据解析参数将表数据文件的字段信息同步到Hive元数据中,在目标集群的数据库中实现Hive建表;读取源集群上Hive元数据库MySQL表,获取每个表每个字段的注释,将注释信息同步到Hive表中。本发明还公开一种基于Spark实现Hudi数据跨集群迁移的工具,其与前述方法相结合,可以实现自动建表、同步元数据,还可以将一个集群的Hudi历史数据全部迁移到另一个集群中,过程简单高效。

本发明授权一种基于Spark实现Hudi数据跨集群迁移的方法及工具在权利要求书中公布了:1.一种基于Spark实现Hudi数据跨集群迁移的方法,其特征在于,包括如下步骤: S1、利用HiveSQL在目标集群下创建数据库,该数据库与源集群的名称和路径相同; S2、利用Hadoop和Linux的命令,将源集群HDFS上的Hudi表数据文件上传到目标集群对应HDFS路径上的数据库中; S3、解析表的配置参数,HiveSyncTool根据解析参数将表数据文件的字段信息同步到Hive元数据中,在目标集群的数据库中实现Hive建表,具体操作流程为: S3.1、利用Hadoop文件系统的API列出数据库路径下的每个表的路径,然后通过表路径解析得到表名; S3.2、遍历表名,判断表路径下是否有Hudi表元数据目录.hoodie, 如果有,则进一步判断是否为Hudi表, 如果是Hudi表,则继续执行步骤S3.3; S3.3、根据spark.sessionState.newHadoopConf和Hudi表路径,获取文件系统fs; S3.4、根据文件系统fs获取配置文件和表路径,进而创建每个表的HoodieTableMetaClient; S3.5、根据HoodieTableMetaClient获取每个表配置信息tableConfig; S3.6、利用tableConfig获取对应的主键字段和分区字段信息; S3.7、根据数据库名、表名、Hudi表路径、分区字段、主键字段构造HiveSyncConfig,利用文件系统fs.getConf创建Hive配置文件hiveConf; S3.8、通过HiveSyncConfig、hiveConf、fs构造Hive同步工具类HiveSyncTool,利用HiveSyncTool的syncHoodieTable方法同步元数据,在目标集群的数据库中实现Hive建表; S4、读取源集群上Hive元数据库MySQL表,获取每个表每个字段的注释,将注释信息同步到步骤S3的Hive表中,具体操作流程为: S4.1、利用SparkSQL的showtables方法,获取目标集群中所有的Hudi表名; S4.2、利用SparkSQL的jdbc方法,读取源集群中Hive元数据库MySQL中的表名字段注释信息; S4.3、利用SparkSQL的jdbc方法,获取目标集群中Hive元数据库MySQL中的表名字段信息,将源集群的表名字段注释中能和目标集群的表名字段匹配上的部分去掉,然后匹配目标集群的表名、字段,构造修改注释SQL:altertable$new_hiveDatabaseName.$hiveTableNamechange$colName$colName$colTypecomment'$comments’; S4.4、利用SparkSQL执行注释SQL,将注释自动同步到目标集群数据库新建的Hive表中。

如需购买、转让、实施、许可或投资类似专利技术,可联系本专利的申请人或专利权人浪潮云信息技术股份公司,其通讯地址为:250100 山东省济南市高新区浪潮路1036号浪潮科技园S01号楼;或者联系龙图腾网官方客服,联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

以上内容由龙图腾AI智能生成。

免责声明
1、本报告根据公开、合法渠道获得相关数据和信息,力求客观、公正,但并不保证数据的最终完整性和准确性。
2、报告中的分析和结论仅反映本公司于发布本报告当日的职业理解,仅供参考使用,不能作为本公司承担任何法律责任的依据或者凭证。