US 11,734,355 B2
Processing queries based on level assignment information
George Kondiles, Chicago, IL (US); and Dave Boutcher, Chicago, IL (US)
Assigned to Ocient Holdings LLC, Chicago, IL (US)
Filed by Ocient Holdings LLC, Chicago, IL (US)
Filed on Apr. 29, 2022, as Appl. No. 17/661,453.
Application 17/661,453 is a continuation of application No. 17/340,553, filed on Jun. 7, 2021.
Application 17/340,553 is a continuation in part of application No. 16/778,194, filed on Jan. 31, 2020, granted, now 11,061,910, issued on Jul. 13, 2021.
Prior Publication US 2022/0261443 A1, Aug. 18, 2022
Int. Cl. G06F 16/903 (2019.01); G06F 16/9038 (2019.01)
CPC G06F 16/90335 (2019.01) [G06F 16/9038 (2019.01)] 20 Claims
OG exemplary drawing
 
1. A method for execution by a processing system of a node, comprising:
determining, by at least one processor of the processing system, first level assignment information indicating assignment to a first subset of levels of a plurality of levels of a computing cluster having a plurality of nodes, wherein the first level assignment information indicates a first compute sequence number;
determining, by the at least one processor of the processing system, second level assignment information indicating assignment to a second subset of levels of the plurality of levels, wherein the second level assignment information indicates a second compute sequence number that is different from the first compute sequence number, wherein the second level assignment information is determined more recently than the first level assignment information;
response to receiving a first query request indicating a query for execution:
identifying, by the at least one processor of the processing system, a compute sequence number tag for the query that indicates a value of the first compute sequence number;
utilizing, by the at least one processor of the processing system, the first level assignment information based on the compute sequence number tag for the query that indicates the value of the first compute sequence number;
processing, by the at least one processor of the processing system, the query at one of the plurality of levels based on determining the one of the plurality of levels is included in the first subset of levels and based on the utilized first level assignment information;
generating, by the at least one processor of the processing system, query resultant data during a temporal period by performing execution of at least one query operator of the query in accordance with the one of the plurality of levels based on to the processing of the query at the one of the plurality of levels, wherein the temporal period begins prior to the determining the second level assignment information, wherein the query resultant data is based on data accessed via a segment storage;
determine a plurality of possible parent nodes in a sequentially higher one of the plurality of levels indicated in a first cluster-level mapping of the first level assignment information based on determining the compute sequence number tag for the query; and
sending, based on the determining of the plurality of possible parent nodes in a sequentially higher one of the plurality of levels, the query resultant data to one of the plurality of possible parent nodes for processing.