CPC G06F 16/245 (2019.01) [G06F 16/24568 (2019.01); G06F 16/258 (2019.01); G06F 16/22 (2019.01); G06F 16/2255 (2019.01); G06F 16/2428 (2019.01); G06F 16/2471 (2019.01)] | 20 Claims |
1. A computing device, comprising:
a memory and a processor, wherein the memory and the processor are respectively configured to store and execute instructions, including instructions for causing the computing device to perform operations, the operations including:
providing a standing query;
synchronizing realtime event data regarding a plurality of assets and static event data regarding the plurality of assets, the synchronizing including obtaining the realtime event data for each of the plurality of assets, the realtime event data for each of the plurality of assets representing that asset at a specific point in time, and the specific point in time for each of the plurality of assets being a same point in time;
merging the synchronized realtime event data regarding the plurality of assets and the static event data regarding the plurality of assets, using one or more operators, into an event stream; and
responsive to a changed data source value:
inputting the event stream as a single event type into the standing query; and
outputting multiple assets of the plurality of assets that match the standing query as output of the standing query according to a latency threshold relative to the changed data source value.
|