Aggregation in dynamic and distributed computing systems

A computing system, comprising:

• a service node;
• and
• a plurality of endpoint nodes;
• wherein the service node is configured to initiate operations including:
• in response to receiving a first query specifying aggregation, translating the first query into a second query having a first canonical format and specifying the aggregation;
• forwarding the second query to a first subset of the plurality of endpoint nodes;
• wherein each endpoint node of the first subset is configured to initiate operations including:
• translating the second query into a third query having a format executable by a data source connected to the selected endpoint node and specifying a level of the aggregation to be performed by the data source determined based upon a processing capability of the data source;
• initiating execution of the third query by the data source;
• and
• providing an aggregated result including a result from the data source to the service node.

A computer program product comprising a computer readable storage medium having program instructions embodied therewith, the program instructions executable by one or more processors to cause the one or more processors to initiate operations comprising:

• in response to receiving, at a service node of a computing system, a first query specifying aggregation, translating the first query into a second query having a first canonical format and specifying the aggregation;
• forwarding the second query to a first subset of a plurality of endpoint nodes of the computing system;
• translating, at each endpoint node of the first subset, the second query into a third query having a format executable by a data source connected to the endpoint node and specifying a level of the aggregation to be performed by the data source determined based upon a processing capability of the data source, wherein each endpoint node initiates execution of the third query by the data source;
• and
• providing, from each endpoint node of the first subset to the service node, an aggregated result including a result from execution of the third query.