基于Flink实现Neo4j数据同步的方法及系统、集成方法及装置

摘要

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