[發明專利]基于Gremlin的并行擴展方法、系統、電子設備及存儲介質

在審

• 申請號: 202110721326.3
• 申請日: 2021-06-28
• 公開（公告）號: CN113535145A
• 公開（公告）日: 2021-10-22
• 發明（設計）人: 鄭天昊
• 申請（專利權）人: 北京明略軟件系統有限公司
• 主分類號: G06F8/30
• 分類號: G06F8/30
• 代理公司: 青島清泰聯信知識產權代理有限公司 37256
• 代理人: 趙燕

1.一種基于Gremlin的并行擴展方法，其特征在于，包括：

并行擴展預置步驟，在編譯器中基于JanusGraph圖擴展接口，通過Gremlin添加一parallel step，并將所述parallel下的全部點信息和邊信息添加至一集合中；

執行邏輯改寫步驟，對所述Gremlin中的VertexStep、EdgeOtherStep和EdgeVertexStep進行執行邏輯的改寫，所述通過繼承所述Gremlin中的AbstractStep并重寫processNextStart()方法實現；

解析攔截替換步驟，在所述Gremlin的解析階段進行攔截，當解析識別到所述parallelstep時，通過改寫后的所述執行邏輯進行執行。

2.根據權利要求1所述的基于Gremlin的并行擴展方法，其特征在于，所述執行邏輯改寫步驟進一步包括：

VertexStep改寫步驟，通過所述JanusGraph中的一并行查詢方法進行一條件傳入操作，若返回為Vertex.class，則執行multiQuery.getEntities方法，若返回為Edge.class，則執行multiQuery.getRelations方法。

3.根據權利要求1所述的基于Gremlin的并行擴展方法，其特征在于，所述執行邏輯改寫步驟進一步包括：

EdgeOtherStep改寫步驟，根據判斷本端點的值來判斷需要獲取的對端點，并將全部所述對端點的ID集合作為條件傳入entityQuery.ids(ids).execute()。

4.根據權利要求1所述的基于Gremlin的并行擴展方法，其特征在于，所述執行邏輯改寫步驟進一步包括：

EdgeVertexStep改寫步驟，根據方向進行判斷，若所述方向為IN，則獲取關系的主體ID，若所述方向為OUT，則獲取關系的客體ID。

5.一種基于Gremlin的并行擴展系統，其特征在于，包括：

并行擴展預置模塊，在編譯器中基于JanusGraph圖擴展接口，通過Gremlin添加一parallel step，并將所述parallel下的全部點信息和邊信息添加至一集合中；

執行邏輯改寫模塊，對所述Gremlin中的VertexStep、EdgeOtherStep和EdgeVertexStep進行執行邏輯的改寫，所述通過繼承所述Gremlin中的AbstractStep并重寫processNextStart()方法實現；

解析攔截替換模塊，在所述Gremlin的解析階段進行攔截，當解析識別到所述parallelstep時，通過改寫后的所述執行邏輯進行執行。

6.根據權利要求5所述的基于Gremlin的并行擴展系統，其特征在于，所述執行邏輯改寫模塊進一步包括：

VertexStep改寫單元，通過所述JanusGraph中的一并行查詢方法進行一條件傳入操作，若返回為Vertex.class，則執行multiQuery.getEntities方法，若返回為Edge.class，則執行multiQuery.getRelations方法。

7.根據權利要求5所述的基于Gremlin的并行擴展系統，其特征在于，所述執行邏輯改寫模塊進一步包括：

EdgeOtherStep改寫單元，根據判斷本端點的值來判斷需要獲取的對端點，并將全部所述對端點的ID集合作為條件傳入entityQuery.ids(ids).execute()。

8.根據權利要求5所述的基于Gremlin的并行擴展系統，其特征在于，所述執行邏輯改寫模塊進一步包括：

EdgeVertexStep改寫單元，根據方向進行判斷，若所述方向為IN，則獲取關系的主體ID，若所述方向為OUT，則獲取關系的客體ID。