Patent ID: 11971894
Assignee: ORACLE INTERNATIONAL CORPORATION
Field: Computer technology (Electrical engineering)
Classification: CPC G | IPC G

Claim 8:
9. A non-transitory computer-readable storage medium storing computer-executable instructions that, when executed by one or more computer systems, configure the one or more computer systems to perform operations comprising:
identifying an archived relation associated with an application, the archived relation comprising a time-bounded window that is created with a combination of i) at least a portion of historical event data and ii) incoming new events of a data stream associated with the application, the historical event data associated with the incoming new events of the data stream and with the application, and the historical event data received from the data stream during a time preceding the creation of the archived relation;
receiving a continuous query to be executed on the archived relation associated with the application, the continuous query being identified based at least in part on the archived relation;
identifying a child operator related to a parent operator in a physical query plan associated with the continuous query of the application, the child operator being identified by the parent operator to store event information related to the application;
inserting a buffer operator that stores events related to the application between the identified child operator and the parent operator in the physical query plan;
determining, based at least in part on the buffer operator, that a first query operator identified in the physical query plan is a same type as a second query operator in a second continuous query of the application that is concurrently executing;
generating a combined query plan based at least in part on the first query operator identified in the physical query plan being the same type as the second query operator in the second continuous query, the combined query plan comprising at least the buffer operator, a parent operator, and a shareable query operator, the shareable query operator having all outputs of both the first query operator and the second query operator;
executing the combined query plan for implementing a combined archiver query to obtain a result set of data records related to the application based at least in part on the shareable query operator;
initializing a buffer state of the buffer operator by constructing a list of tuples from the result set of data records, at least one tuple in the list of tuples being constructed based at least in part on a subset of attributes in the result set of data records; and
generating a snapshot output of one or more data values related to the application based at least in part on the buffer state of the buffer operator.