Granted Patent B2

US 11,657,041 · App. 16/997,392 · Granted May 23, 2023

Inventor: Paul Peloski (Calgary, CA)

Assignee: TTEC Holdings, Inc.

G06F16/2393G06F16/2246G06F16/245G06F16/24561G06F30/20

Abstract

Claims (23)

1. A system operating a persistent query service stored and operating on a computer comprising at least a processor and a memory, the system comprising:

a plurality of programming instructions stored in the memory and operating on the processor;

wherein, when operating the programming instructions, the processor provides the persistent query service that:

receives a request from a client software application to create a persistent query from a client software application;

creates a query virtual table corresponding to the requested persistent query;

parses the persistent query to create a tree structure representing a logical arrangement of a plurality of operators required by the persistent query;

creates a plurality of intermediate virtual tables corresponding to the plurality of operators,

establishes listeners associated with the plurality of intermediate virtual tables to receive data change notifications;

establishes a listener for the query virtual table to receive data change notifications pertaining to the plurality of intermediate virtual tables;

creates a plurality of data source virtual tables, each corresponding to a specific data source required to fulfill the persistent query;

causes the plurality of data source virtual tables to retrieve initial data from the plurality of data sources; and

propagates data via the plurality of intermediate virtual tables and their associated listeners to the persistent query virtual table; and

wherein, on detection of a data change in a data source, the associated data source virtual table:

invokes a plurality of corresponding methods of listeners of a plurality of virtual intermediate tables;

propagates the data change to the persistent query virtual table; and

updates a plurality of aggregations of data in tables when the data change is made against a table;

wherein the invocation, propagation, and updating steps are performed immediately as data changes occur in a real-time database, without compromising performance.

2. The system of claim 1 , wherein at least one intermediate virtual table is a projection table.

3. The system of claim 1 , wherein at least one intermediate virtual table is a group-by table.

4. The system of claim 1 , wherein at least one intermediate virtual table is an inner join table.

5. The system of claim 1 , wherein at least one intermediate virtual table is a filter table.

6. The system of claim 1 , further comprising a plurality of network interfaces.

7. The system of claim 6 , wherein the persistent query service is configured to receive queries from network-connected devices via a network interface.

Assignments (4)

Continuity (12)