| CPC G06Q 10/06315 (2013.01) [G06F 16/25 (2019.01); G06Q 10/06393 (2013.01)] | 17 Claims |
|
1. A node in a blockchain network, the node comprising:
a memory storing one or more instructions; and
a processor that, when executing the one or more instructions, is configured to:
generate an asset containment world-state table that represents latest values for all keys included in a chain transaction log of a blockchain of the blockchain network, wherein rows of the asset containment world-state table correspond to events associated with assets, and wherein each row comprises a start-time field, an end-time field, a start-time-upper-bound field, and an end-time-lower-bound field;
detect that an event associated with an asset occurs at time T1, wherein the event comprises an aggregation event or a disaggregation event;
using a smart contract, read key-value pairs stored in the blockchain;
using the smart contract, identify a row in the asset containment world-state table corresponding to a prior event associated with the asset using the key-value pairs that have been read, wherein it is determined that the row needs to be split to create a new row corresponding to the event in response to the event being identified as a child of the prior event based on a start-time-lower-bound field of the row having a value less than or equal to T1 and an end-time-upper-bound field of the row having a value greater than T1, and wherein the prior event is one of the aggregation event or the disaggregation event associated with the asset;
using the smart contract, determine using a linear-time ingestion algorithm that the event occurs in one of an aggregation/disaggregation interval of the prior event, an aggregation/aggregation interval of the prior event, or an aggregation/disaggregation interval of the prior event using the start-time field of the event, the end-time field of the event, the start-time-lower-bound field of the event, and the end-time-upper-bound field of the event;
in response to the determination, using the smart contract to modify the asset containment world-state table to have a new row corresponding to the event by splitting the row corresponding to the prior event into a first row corresponding to the prior event and the new row using the linear-time ingestion algorithm to execute a one-shot ingestion modifying the asset containment world-state table only once, wherein the aggregation/disaggregation event does not modify the asset containment world-state table again even if it is received in an out-of-time order; and
using the smart contract, compute a low-latency, real-time estimation of supply-chain metrics based on the modified updated world-state table using a smart contract of the blockchain.
|