基于Flink实现Neo4j数据同步的方法及系统、集成方法及装置
摘要:
本申请提供一种基于Flink实现Neo4j数据同步的方法及系统、集成方法及装置,基于Flink实现Neo4j数据同步的集成方法包括:提供经建立的项目的核心依赖及其版本,所述核心依赖至少包括Flink依赖以及Neo4j依赖;提供经建立的数据转换映射器,所述数据转换映射器用于将数据对象转换为Neo4j cypher格式片段;提供经重写的基于对所述Flink依赖中的部分方法,其中,在重写的部分方法中基于所述数据转换映射器完成数据对象与Neo4j cypher格式片段的转换,以提供经建立的Flink写入Neo4j图数据库的处理组件。本申请实现高效简洁、灵活自由的Neo4j数据同步方案。
0/0