Processing complex aggregate queries over data streams | Synapse