Logical queries in a distributed stream processing system

A system comprising:

• a data processing system that includes one or more processors and non-transitory machine readable storage medium having instructions stored thereon that when executed by the one or more processors cause the one or more processors to perform the process comprising:
• determining, by the data processing system, a query is a logical query, wherein the logical query includes two or more summaries based on different groups configured to execute in a single query stage of a stream analytics application;
• converting, by the data processing system, the logical query into one or more physical queries, wherein the one or more physical queries are separated into individual query stages, and each of the query stages includes a summary from the two or more summaries that is based on an associated group;
• and
• generating, by the data processing system, a directed acyclic graph for the one or more physical queries, wherein the directed acyclic graph includes a physical query transformation for each of the individual query stages.

A non-transitory machine readable storage medium having instructions stored thereon that when executed by one or more processors cause the one or more processors to perform a method comprising:

• determining a query is a logical query, wherein the logical query includes two or more summaries based on different groups configured to execute in a single query stage of a stream analytics application;
• converting the logical query into one or more physical queries, wherein the one or more physical queries are separated into individual query stages, and each of the query stages includes a summary from the two or more summaries that is based on an associated group;
• and
• generating a directed acyclic graph for the one or more physical queries, wherein the directed acyclic graph includes a physical query transformation for each of the individual query stages.