cassandra_tables.cql

DROP KEYSPACE IF EXISTS plume;
CREATE KEYSPACE plume WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor' : 1 };

use plume;

create type plume.pollution_data (
   value_upm float,
   pi float,
   aqi float,
   aqi_cn float
);

create table plume.pollution_data_by_lat_lon (
   latitude double,
   longitude double,
   timestamp bigint,
   pm_data frozen <pollution_data>,
   nitrous_data frozen <pollution_data>,
   pm_data_ten frozen <pollution_data>,
   pm_data_twenty_five frozen <pollution_data>,
   ozone_data frozen <pollution_data>,
   overall_data frozen <pollution_data>,
   primary key ((latitude, longitude), timestamp)
)
with clustering order by (timestamp desc);