Introducing Riak TS

Riak TS is a distributed NoSQL database and key/value store optimized for fast reads and writes of time series data.
It provides a rich set of feature like data co-location and range queries, which make queries faster and easier to run.

Seek Wisdom

Overview

The Riak product line includes Riak KV, Riak S2, and Riak TS

Riak KV — Store unstructured data (JSON, XML, HTML, binaries)

Riak S2 — Large object storage (TB & PB)

Riak TS — Optimized for time series data

These Storage Instances are part of the Basho Data Platform.

Basho Data Platform Riak TS

Basho Data Platform

Distributed, scalable, fault tolerant framework and resource manager,

Includes:

  • Core Services (e.g. replication)
  • Storage Instances (e.g. Riak TS)
  • Service Instances (e.g. Spark)

    • Riak TS

    Time series data is unique, requiring:

  • Data co-location
  • High performance reads and writes
  • Ability to retrieve data using range queries

    • Optimized Data Store

    Query large amounts of time series data efficiently
    by storing related data next to each other.

    Optimize

    Optimized Data Store

    Riak TS co-locates data to enable fast reads and writes.

    Data Modeling

    Key/value NoSQL data model provides flexibility.
    Developers can define their own schema using DLL.

    Data Modeling

    Data Modeling

    In order to query time series data, the data is stored in a schema.
    The schema defines what data can be stored in a time series bucket and what type it has.

    Queries can then be written against that schema and the Riak TS query system can validate and execute them.

  • Measurements include temperature, conductance, salinity, and turbidity.
  • Data for 1 week at 15 minute interval has been collected and loaded into Riak.

    • Bucket Type Creation

    Writing Data

    Riak TS allows you to write multiple rows of data at a time
    by simply putting the data in a list.

    Write Data

    Write Data

    Riak TS allows you to write multiple rows of data at a time by simply putting data in a list.

    Java TS Insertion

    Reading Data

    Riak TS enables range queries, which enable you
    to read data within a specific time period.

    Read Data

    Read Data

    Now that we have written data to the Riak TS bucket, we can query it.

    Consider the WaterData table we created earlier:

    Cluster Create

    You can also select particular fields and extend the query beyond the primary keys.

    Cluster Create