← 返回列表
基于Hadoop架构的数据精简方法和系统
摘要文本
本发明提供一种基于Hadoop架构的数据精简方法和系统。具体包括:对于Hadoop架构下的hive2clickhouse的数据同步任务,hive任务的每次运行过程中,增加同步时间字段;clickhouse系统的任务表以该同步时间字段为分区字段,建立新的分区,并设置适当的TTL值;hive任务重跑的时候产生的数据,会基于该同步时间字段进入clickhouse任务表中新的分区;clickhouse系统的bi查询引擎获取该新的分区的数据,执行查询处理;该处理过程中不会出现数据重复和翻倍的现象。
申请人信息
- 申请人:蒲惠智造科技股份有限公司
- 申请人地址:310002 浙江省杭州市上城区庆春东路1-1号(临)5层
- 发明人: 蒲惠智造科技股份有限公司
专利详细信息
| 项目 | 内容 |
|---|---|
| 专利名称 | 基于Hadoop架构的数据精简方法和系统 |
| 专利类型 | 发明授权 |
| 申请号 | CN202311630505.1 |
| 申请日 | 2023/12/1 |
| 公告号 | CN117331513B |
| 公开日 | 2024/3/19 |
| IPC主分类号 | G06F3/06 |
| 权利人 | 蒲惠智造科技股份有限公司 |
| 发明人 | 王克飞; 徐超; 应春红 |
| 地址 | 浙江省杭州市上城区庆春东路1-1号(临)5层 |
专利主权项内容
1.一种基于Hadoop架构的数据精简方法,其特征在于,包括:步骤S1,对于Hadoop架构下的hive2clickhouse的数据同步任务,hive任务的每次运行过程中,增加同步时间字段;步骤S2,clickhouse系统的任务表以该同步时间字段为分区字段,建立新的分区,并设置适当的TTL值;步骤S3,hive任务重跑的时候产生的数据,会基于该同步时间字段进入clickhouse任务表中新的分区,包括:hive任务每次重跑过程中产生的数据首先暂存于hive的存储分区中;对hive存储分区的各个分区进行自动比对,确定存在数据重复的分区;并且,对于属于数据重复的分区,进行重复数据关联去重处理;对于重复数据关联去重处理后的分区,将其关联的同步时间字段更新为最新的同步时间字段;以分区为单位同步到clickhouse任务表中新的分区;步骤S4,clickhouse系统的bi查询引擎获取该新的分区的数据,执行查询处理;该处理过程中不会出现数据重复和翻倍的现象。