数据搬移方法、装置及PCIE系统

    公开(公告)号:CN113434089B

    公开(公告)日:2022-08-16

    申请号:CN202110729104.6

    申请日:2021-06-29

    IPC分类号: G06F3/06 G06F9/50 G06F13/42

    摘要: 本发明提供一种数据搬移方法、装置及PCIE系统,应用于从机设备的数据搬移方法,包括:配置从机设备的内存空间;建立从机设备的内存空间和主机设备的内存空间的映射,形成所述从机设备和所述主机设备之间的第一共享内存,所述第一共享内存至少用以进行地址信息的传输;经由向外映射的方式对所述第一共享内存的地址信息进行映射,以执行主机设备至从机设备以及从机设备至主机设备的数据搬移。本申请优化主机设备和从机设备之间的数据搬移,降低主机设备的CPU占用率,提升整个系统的扩展性,同时提高主机设备和从机设备之间的传输性能。

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

    公开(公告)号:CN113111131A

    公开(公告)日:2021-07-13

    申请号:CN202110485131.3

    申请日:2021-04-30

    IPC分类号: G06F16/27 G06F16/25

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

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

    公开(公告)号:CN113111131B

    公开(公告)日:2022-07-08

    申请号:CN202110485131.3

    申请日:2021-04-30

    IPC分类号: G06F16/27 G06F16/25

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

    数据搬移方法、装置及PCIE系统

    公开(公告)号:CN113434089A

    公开(公告)日:2021-09-24

    申请号:CN202110729104.6

    申请日:2021-06-29

    IPC分类号: G06F3/06 G06F9/50 G06F13/42

    摘要: 本发明提供一种数据搬移方法、装置及PCIE系统,应用于从机设备的数据搬移方法,包括:配置从机设备的内存空间;建立从机设备的内存空间和主机设备的内存空间的映射,形成所述从机设备和所述主机设备之间的第一共享内存,所述第一共享内存至少用以进行地址信息的传输;经由向外映射的方式对所述第一共享内存的地址信息进行映射,以执行主机设备至从机设备以及从机设备至主机设备的数据搬移。本申请优化主机设备和从机设备之间的数据搬移,降低主机设备的CPU占用率,提升整个系统的扩展性,同时提高主机设备和从机设备之间的传输性能。