Subqueries in distributed asynchronous graph queries
A graph processing engine is provided for executing a graph query comprising a parent query and a subquery nested within the parent query. The subquery is an existential subquery, uses a reference to one or more correlated variables from the parent query, is inlined in the parent query pattern matching, does not have a post-processing phase, does not contain any global aggregation operations, uses a reference to at most one non-correlated variable, and does not include any filters on a non-correlated variable. Executing the graph query comprises initiating execution of the parent query, responsive to the parent query matching the one or more correlated variables in an intermediate result set, executing the subquery by applying a neighbor pattern matching operator that checks for existence of an edge, and resuming execution of the parent query based on results of the neighbor pattern matching operation.
1. A computer-executed method comprising:
a graph processing engine executing a graph query, wherein:
the graph query comprises a parent query and a subquery nested within the parent query;
the subquery is an existential subquery returning a Boolean value that depends on whether the subquery produces at least one match result;
the subquery uses a reference to one or more correlated variables from the parent query;
the subquery is inlined in the parent query pattern matching, does not have a post-processing phase, and does not contain any global aggregation operations;
the subquery uses a reference to at most one non-correlated variable;
the subquery does not include any filters on a non-correlated variable;
executing the graph query comprises:
initiating execution of the parent query, wherein the parent query matches the one or more correlated variables in an intermediate result set;
responsive to the parent query matching the one or more correlated variables in the intermediate result set, executing the subquery by applying a neighbor pattern matching operator that checks for existence of an edge; and
resuming execution of the parent query based on results of the neighbor pattern matching operation.
2. The method of claim 1 , wherein executing the subquery comprises initiating execution of the subquery at a last variable, of the one or more correlated variables, visited by the parent query.
3. The method of claim 2 , wherein the neighbor pattern matching operation comprises an operator that checks an edge list of the last variable visited by the parent query and produces a match only if no suitable edges are found.
4. The method of claim 2 , wherein the neighbor pattern matching operation comprises an operator that checks an edge list of the last variable visited by the parent query and produces a match only if a suitable edge is found.
5. The method of claim 1 , wherein executing the graph query comprises executing the subquery using asynchronous distributed graph traversals.
6. The method of claim 1 , wherein initiating execution of the parent query comprises initiating asynchronous graph traversals in a first pattern matching phase of the parent query.
7. The method of claim 6 , wherein resuming execution of the parent query comprises resuming asynchronous graph traversals in a second pattern matching phase of the parent query.
8. The method of claim 6 , wherein resuming execution of the parent query comprises initiating execution of operations that require bulk-synchronous execution in a post-processing phase of the parent query.
9. The method of claim 1 , wherein the graph query is a subquery of another graph query.
10. One or more non-transitory storage media storing instructions which, when executed by one or more computing devices, cause:
a graph processing engine executing a graph query, wherein:
the graph query comprises a parent query and a subquery nested within the parent query;
the subquery is an existential subquery returning a Boolean value that depends on whether the subquery produces at least one match result;
the subquery uses a reference to one or more correlated variables from the parent query;
the subquery is inlined in the parent query pattern matching, does not have a post-processing phase, and does not contain any global aggregation operations;
the subquery uses a reference to at most one non-correlated variable;
the subquery does not include any filters on a non-correlated variable;
executing the graph query comprises:
initiating execution of the parent query, wherein the parent query matches the one or more correlated variables in an intermediate result set;
responsive to the parent query matching the one or more correlated variables in the intermediate result set, executing the subquery by applying a neighbor pattern matching operator that checks for existence of an edge; and
resuming execution of the parent query based on results of the neighbor pattern matching operation.
11. The method of claim 10 , wherein executing the subquery comprises initiating execution of the subquery at a last variable, of the one or more correlated variables, visited by the parent query.
12. The method of claim 11 , wherein the neighbor pattern matching operation comprises an operator that checks an edge list of the last variable visited by the parent query and produces a match only if no suitable edges are found.
13. The method of claim 11 , wherein the neighbor pattern matching operation comprises an operator that checks an edge list of the last variable visited by the parent query and produces a match only if a suitable edge is found.
14. The method of claim 10 , wherein executing the graph query comprises executing the subquery using asynchronous distributed graph traversals.
15. The method of claim 10 , wherein initiating execution of the parent query comprises initiating asynchronous graph traversals in a first pattern matching phase of the parent query.
16. The method of claim 15 , wherein resuming execution of the parent query comprises resuming asynchronous graph traversals in a second pattern matching phase of the parent query.
17. The method of claim 15 , wherein resuming execution of the parent query comprises initiating execution of operations that require bulk-synchronous execution in a post-processing phase of the parent query.
18. The method of claim 10 , wherein the graph query is a subquery of another graph query.