Aggregations

Aggregation saves time.

You don’t have time to look at millions and billions of data points. Counting, summing, or averaging data makes it easy to identify data trends or make real-time decisions. Riak TS provides aggregation functions, so you can quickly look at data rollups over time.

With Riak TS, you can create SQL range queries using common aggregations like COUNT, SUM, AVG / MEAN, MIN, MAX, or STDDEV. Aggregations make it easy to analyze massive amounts of time series data.

SUMMARY ANALYSIS REQUIRES AGGREGATION

Over time, individual time series data points are less valuable than aggregate data, especially when doing summary analysis. Riak TS offers built-in aggregations to enhance your SQL queries.

The Aggregate Functions supported in Riak TS include:

COUNT() — Returns the number of entries that match a specified criteria
SUM() — Returns the sum of entries that match a specified criteria
AVG() & MEAN() — Returns the average of entries that match a specified criteria
MIN() — Returns the smallest value of entries that match a specified criteria
MAX() — Returns the largest value of entries that match a specified criteria
STDDEV() — Returns the statistical standard deviation of all entries that match a specified criteria using Population Standard Deviation

SELECT AVG(temperature) from WEATHER
WHERE city = 'Seattle' AND 
      location = 'Bellevue' AND
      time >= 1451606400000 AND
      time <= 1454284800000;

The above SELECT statement assumes a range query on the table created below:

table = 'WEATHER'
fmt = """CREATE TABLE {table} (
city varchar not null,
location varchar not null,
time timestamp not null,
weather varchar not null,
temperature double,
PRIMARY KEY ((myfamily, myseries, quantum(time, 2, 'h')),
myfamily, myseries,, time))
"""
query = fmt.format(table=table)
ts_obj - client.ts_query(table,query)

BENEFITS OF AGGREGATIONS

To do summary analysis, Riak TS includes aggregation functions to make it faster to analyze data across time.

Make better business decisions
As time series data ages, summary analysis becomes increasingly important for extracting value from the data. This analysis allows you to see trends, spot anomalies, review data variability, measure margin of error, and much more. Riak TS with aggregation functionality ensures better decision making through summary analysis.

Improve customer experience
Whether you’re sharing average temperature, the Dow Jones average, or the maximum amount of CPU usage, you have to look at data aggregated over time. Riak TS uses common aggregations to reduce query times providing a better customer experience.

Increase performance
The volume of historical data increases with every passing moment. To gain insights from this data, you need to be able to quickly summarize it for analysis, which requires highly performant data aggregation. With Riak TS built-in aggregations your SQL queries easily return summary data.