Scalable Simulation System with Scalable Data Propagation
First Claim
1. One or more non-transitory computer readable media storing computer executable instructions that, when executed, cause a system to perform a simulation by:
- receiving an indication of a streaming query for each worker of a plurality of workers in a worker layer of the simulation;
running, on a plurality of machines, a plurality of bridges in a bridge layer of the simulation, wherein the plurality of bridges are configured to facilitate data communications between the plurality of workers in the worker layer and one or more databases in a database layer of the simulation;
assigning each worker of the plurality of workers to a different bridge of the plurality of bridges; and
based on the streaming query for each worker, grouping the plurality of bridges into different groups of bridges, wherein each group of bridges is running on a different machine of the plurality of machines.
1 Assignment
0 Petitions
Accused Products
Abstract
Methods, systems, computer-readable media, and apparatuses for grouping bridges in a simulation are presented. In some examples, grouping bridges may result in more efficient usage of data connections in a simulation and less duplicative data being sent during the simulation. The simulation may be performed by receiving an indication of a streaming query for each worker of a plurality of workers in a worker layer. A plurality of bridges in a bridge layer may be run, and the plurality of bridges may be configured to facilitate data communications between the plurality of workers in the worker layer and one or more databases in a database layer. Each worker of the plurality of workers may be assigned to a different bridge of the plurality of bridges. Based on the streaming query for each worker, the plurality of bridges may be grouped into different groups of bridges.
-
Citations
20 Claims
-
1. One or more non-transitory computer readable media storing computer executable instructions that, when executed, cause a system to perform a simulation by:
-
receiving an indication of a streaming query for each worker of a plurality of workers in a worker layer of the simulation; running, on a plurality of machines, a plurality of bridges in a bridge layer of the simulation, wherein the plurality of bridges are configured to facilitate data communications between the plurality of workers in the worker layer and one or more databases in a database layer of the simulation; assigning each worker of the plurality of workers to a different bridge of the plurality of bridges; and based on the streaming query for each worker, grouping the plurality of bridges into different groups of bridges, wherein each group of bridges is running on a different machine of the plurality of machines. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11)
-
-
12. A method comprising:
-
receiving, by a computing device, an indication of a streaming query for each worker of a plurality of workers in a worker layer of a simulation; running, on a plurality of machines, a plurality of bridges in a bridge layer of the simulation, wherein the plurality of bridges are configured to facilitate data communications between the plurality of workers in the worker layer and one or more databases in a database layer of the simulation; assigning, by the computing device, each worker of the plurality of workers to a different bridge of the plurality of bridges; and based on the streaming query for each worker, grouping, by the computing device, the plurality of bridges into different groups of bridges, wherein each group of bridges is running on a different machine of the plurality of machines. - View Dependent Claims (13, 14, 15, 16)
-
-
17. An apparatus comprising:
-
one or more computer processor controlling some operations of the apparatus; and memory storing computer-executable instructions that, when executed by the one or more computer processor, cause the apparatus to; receive an indication of a streaming query for each worker of a plurality of workers in a worker layer of a simulation; run, on a plurality of machines, a plurality of bridges in a bridge layer of the simulation, wherein the plurality of bridges are configured to facilitate data communications between the plurality of workers in the worker layer and one or more databases in a database layer of the simulation; assign each worker of the plurality of workers to a different bridge of the plurality of bridges; and based on the streaming query for each worker, group the plurality of bridges into different groups of bridges, wherein each group of bridges is running on a different machine of the plurality of machines. - View Dependent Claims (18, 19, 20)
-
Specification