Abstract:
An example system for distributing a workload of an application includes a class identifier that identifies a remotely instantiable class in an instruction. Execution of the instruction includes processing a workload. The example system also includes a distributor that selects a remote node to process a portion of the workload, sends a message to the selected remote node to cause (i) the selected remote node to instantiate the remotely instantiable class and (ii) the selected remote node to process the portion of the workload by invoking a method of the instantiated class, and receives a result of the processed portion of the workload.
Abstract:
Systems and methods are provided for data hub architecture to provide actionable data from remote sensor feeds. An exemplary method includes receiving, by a master hub of a plurality of data hubs, a request to access at least one first sensor in a first location and at least one second sensor in a second location from a data client, wherein the master hub is closest to the data client of the plurality of data hubs on a network, determining a first data hub that is closest to the at least one first sensor on the network, and determining a second data hub that is closest to the at least one second sensor on the network. The method further includes querying the first data hub and the second data hub for data and communicating the data to the data client.
Abstract:
An example method for routing a message in a dynamic service mesh includes receiving at a mesh point a first message from a sender service and determining, based on a routing table, whether the mesh point has previously received a second message from the sender service. When the mesh point is determined to not have received the second message from the sender service, the first message is routed to a target service in the dynamic service mesh. The method includes receiving an indication of whether the first message has been accepted by the target service and updating the routing table based on the indication. When the indication indicates that the first message has been rejected by the target service, the first message is routed from the mesh point to a second target service.
Abstract:
An example method of processing a plurality of queries includes determining, at a database driver, that a first query and a second query are similar. The first query is sent from a first execution thread executing in an application server. The method also includes generating, at the database driver, a union query based on the first and second queries. The method further includes submitting the union query to a database that stores database tables from which data is selected based on the first and second queries. The method also includes receiving a combined result set of the union query from the database and submitting the first query against the combined result set. The method further includes receiving, at the database driver, a first result set of the first query in response to submitting the first query against the combined result set.
Abstract:
An example method of processing a federated query includes receiving a first federated query from a first client and receiving a second federated query from a second client. The first federated query includes a first source query that is in accordance with a target data source's query model, and the second federated query includes a second source query. The method also includes sending the second source query to the target data source and determining whether the second source query has failed at the target data source. The method further includes in response to determining that the second source query has failed, migrating the second source query in accordance with the first source query.
Abstract:
An example method for processing a federated query includes determining, at a data federation tool, a source query embedded in a federated query. The source query includes a name of a table and one or more conditions for selecting data from the table. The method also includes sending, at the data federation tool, a request to compile a software package in accordance with a view description of the table to a data slave. The software package includes a set of source files and is associated with the table. The method further includes sending the source query to the data slave and receiving, at the data federation tool, the result of the source query from the data slave.
Abstract:
A system and method of batch query processing includes accumulating data queries in a query holding area of a query assistant running in a computer server, separating the accumulated data queries into a plurality of partitions, ordering the partitions, ordering the accumulated data queries within each of the partitions, and processing the accumulated data queries in an order based on the ordering of the partitions and the ordering of the data queries within each of the partitions. Each of the partitions includes data queries with a respective from-type. Each respective from-type is associated with a combination of storage tables accessed by each of the data queries in a corresponding partition. In some examples, ordering the accumulated data queries within each of the partitions includes processing the data queries in each partition against a test data set and ordering the data queries based on results of the processing.
Abstract:
A method and system for processing a request is provided. An example system includes a security module that authenticates a request from a client. The system also includes a Web service that determines whether the set of operations includes an input/output (I/O) operation and determines whether a result of the authentication has been determined. While the request is pending authentication, the Web service may initiate processing of the request and may ensure that no I/O operations are performed within the processing of the request until a request of the authentication has been determined.
Abstract:
A cache system stores a number of different datasets. The cache system includes a number of cache units, each in a state associated with one of the datasets. In response to determining that a hit ratio of a cache unit drops below a threshold, the state of the cache unit is changed and the dataset is replaced with that associated with the new state.
Abstract:
A system and method of dynamic collaboration during query processing includes determining a load factor for a data source, receiving a query at a query assistant running on a computer server, determining a complexity of the query, adjusting the complexity by the load factor, simplifying the query by removing one or more first query elements from the query when the adjusted complexity is above a threshold, forming a query plan where the first query elements are designated for processing outside the data source, and performing the query plan by sending one or more abbreviated queries to the data source and processing the first query elements using the query assistant. The abbreviated queries are based on the query with the first query elements removed. In some examples, the query may be iteratively simplified until a second adjusted complexity of a simplified version of the query falls below the threshold.