Cassandra - Aggregat Zeitstempel pro Stunde

Question

Ich habe eine Tabelle mit Zeitstempeln in einem 15-Minuten-Intervall. Es ist möglich, zu aggregieren oder zu gruppieren, indem Stunde und das load Feld der Durchschnitt ist?

Answer 1

Theres eine post auf materialisierte Ansichten. Sie können damit eine Kopie der nach Stunden gestapelten Daten erstellen. Verwenden Sie dann die durchschnittlichen Aggregatfunktionen beim Laden. Ich denke, CASSANDRA-11871 Ist das, was Sie suchen, obwohl alle seine Abhängigkeiten in group by vor kurzem abgeschlossen wurde, aber noch nicht bearbeitet worden ist.

Kinda nur raten auf dem Schema, aber so etwas wie (Disclaimer nicht wirklich getestet):

CREATE TABLE load (
ref_equip text, 
ptd_assoc text, 
date timestamp, 
date_hour bigint, 
load float, 
PRIMARY KEY ((ref_equip, ptd_assoc), date) 
); 

CREATE MATERIALIZED VIEW load_by_hour AS 
SELECT * FROM load 
WHERE ref_equip IS NOT NULL AND ptd_assoc IS NOT NULL 
PRIMARY KEY ((ref_equip, ptd_assoc), date_hour, date); 

wo date_hour nur der Zeitstempel mit Stunde Auflösung ist, teilt Bedeutung von 1000 * 60 * 60 (epoc ist ms) wenn Sie einfügen. Kann dann durchschnittlich wählen

SELECT avg(load) FROM load_by_hour WHERE ref_equip='blarg' AND ptd_assoc='blargy' AND date_hour = 410632; 

Alternativ etwas, das nur besser sein kann, mit beginnen Sie Daten zu speichern, die von Stunde aufgeteilt:

CREATE TABLE load (
ref_equip text, 
ptd_assoc text, 
date timestamp, 
date_hour bigint, 
load float, 
PRIMARY KEY ((ref_equip, ptd_assoc, date_hour), date) 
);