Patent ID: 11921708
Assignee: SNOWFLAKE INC.
Field: Computer technology (Electrical engineering)
Classification: CPC G | IPC G

Claim 10:
11. A method comprising:
receiving, at a first execution node, a first transaction, the first transaction to be executed on linearizable storage;
determining a first read timestamp associated with the first transaction, the first read timestamp comprising a first read version, the first read version indicating a first version of the linearizable storage;
determining whether the first execution node corresponds to a rank indicating a leader worker;
in response to the first execution node corresponding to the rank indicating the leader worker, performing, by the first execution node, an initialization process for executing the first transaction, the initialization process comprising:
broadcasting, by the first execution node, the first read timestamp associated with the first transaction to a set of execution nodes, the set of execution nodes being different than the first execution node, individual nodes of the set of execution nodes performing corresponding operations from the first transaction in response to receiving the first read timestamp; and
executing, by the first execution node, at least a first operation from the first transaction based on the first execution node corresponding to the rank of the leader worker;
receiving, at the first execution node, a broadcast of a second read timestamp from the leader worker for a second transaction;
determining, by the first execution node, that the first execution node is a follower worker for the second transaction in response to receiving the broadcast of the second read timestamp; and
in response to determining that the first execution node is the follower worker for the second transaction:
blocking receipt of a third read timestamp associated with a third transaction;
executing, by the first execution node, at least a second operation from the second transaction based on the first read timestamp and the second read timestamp; and
disable blocking of the receipt of the third read timestamp associated with the third transaction.