Changeset: 0accdd5dbdc2 for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=0accdd5dbdc2
Added Files:
sql/test/timetrails/Tests/retention.sql
sql/test/timetrails/Tests/summary.sql
Modified Files:
sql/test/timetrails/Tests/All
Branch: timetrails
Log Message:
A few more critical steps for timeseries
diffs (69 lines):
diff --git a/sql/test/timetrails/Tests/All b/sql/test/timetrails/Tests/All
--- a/sql/test/timetrails/Tests/All
+++ b/sql/test/timetrails/Tests/All
@@ -8,3 +8,5 @@ derivative
windowfunction
rieman
microbatch
+summary
+retention
diff --git a/sql/test/timetrails/Tests/retention.sql
b/sql/test/timetrails/Tests/retention.sql
new file mode 100644
--- /dev/null
+++ b/sql/test/timetrails/Tests/retention.sql
@@ -0,0 +1,23 @@
+-- Remove some of the tuples
+
+CREATE TABLE rooms_min(tick timestamp, room string, level integer, temp
integer);
+
+CREATE PROCEDURE retention(stride integer)
+BEGIN
+ DELETE FROM rooms
+ WHERE now() - stride >tick;
+END;
+
+CALL timetrails.register('sys','retention');
+CALL timetrails.heartbeat('sys','retention',60);
+CALL timetrails.resume();
+CALL timetrails.wait(500);
+CALL timetrails.pause();
+
+SELECT * FROM timetrails.status();
+CALL timetrails.deregister('sys','retention');
+
+SELECT * FROM rooms_min;
+
+DROP PROCEDURE retention;
+DROP TABLE rooms_min;
diff --git a/sql/test/timetrails/Tests/summary.sql
b/sql/test/timetrails/Tests/summary.sql
new file mode 100644
--- /dev/null
+++ b/sql/test/timetrails/Tests/summary.sql
@@ -0,0 +1,27 @@
+-- summarize the table at regular minute intervals
+
+CREATE TABLE rooms_min(tick timestamp, room string, level integer, temp
integer);
+
+CREATE PROCEDURE summarize(stride integer)
+BEGIN
+ INSERT INTO rooms_min
+ WITH T(tick, period, room, level, temp)
+ AS ( SELECT min(tick), epoch(tick)/stride AS period, room, level,
avg(temp)
+ FROM rooms
+ GROUP BY period, room, level)
+ SELECT tick,room,level,temp FROM T;
+END;
+
+CALL timetrails.register('sys','summarize');
+CALL timetrails.heartbeat('sys','summarize',60);
+CALL timetrails.resume();
+CALL timetrails.wait(500);
+CALL timetrails.pause();
+
+SELECT * FROM timetrails.status();
+CALL timetrails.deregister('sys','summarize');
+
+SELECT * FROM rooms_min;
+
+DROP PROCEDURE summarize;
+DROP TABLE rooms_min;
_______________________________________________
checkin-list mailing list
[email protected]
https://www.monetdb.org/mailman/listinfo/checkin-list
