- 专利标题: 基于Flink实现Neo4j数据同步的方法及系统、集成方法及装置
-
申请号: CN202110485131.3申请日: 2021-04-30
-
公开(公告)号: CN113111131A公开(公告)日: 2021-07-13
- 发明人: 管峻宇 , 许路路 , 朱俊 , 张炜
- 申请人: 苏州科达科技股份有限公司
- 申请人地址: 江苏省苏州市高新区金山路131号
- 专利权人: 苏州科达科技股份有限公司
- 当前专利权人: 苏州科达科技股份有限公司
- 当前专利权人地址: 江苏省苏州市高新区金山路131号
- 代理机构: 上海隆天律师事务所
- 代理商 潘一诺
- 主分类号: G06F16/27
- IPC分类号: G06F16/27 ; G06F16/25
摘要:
本申请提供一种基于Flink实现Neo4j数据同步的方法及系统、集成方法及装置,基于Flink实现Neo4j数据同步的集成方法包括:提供经建立的项目的核心依赖及其版本,所述核心依赖至少包括Flink依赖以及Neo4j依赖;提供经建立的数据转换映射器,所述数据转换映射器用于将数据对象转换为Neo4j cypher格式片段;提供经重写的基于对所述Flink依赖中的部分方法,其中,在重写的部分方法中基于所述数据转换映射器完成数据对象与Neo4j cypher格式片段的转换,以提供经建立的Flink写入Neo4j图数据库的处理组件。本申请实现高效简洁、灵活自由的Neo4j数据同步方案。
公开/授权文献
- CN113111131B 基于Flink实现Neo4j数据同步的方法及系统、集成方法及装置 公开/授权日:2022-07-08