Changeset: d7a8b53046b4 for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=d7a8b53046b4
Modified Files:
sql/backends/monet5/iot/Tests/iot00.sql
sql/backends/monet5/iot/Tests/iot05.sql
Branch: iot
Log Message:
minor text
diffs (60 lines):
diff --git a/sql/backends/monet5/iot/Tests/iot00.sql
b/sql/backends/monet5/iot/Tests/iot00.sql
--- a/sql/backends/monet5/iot/Tests/iot00.sql
+++ b/sql/backends/monet5/iot/Tests/iot00.sql
@@ -1,16 +1,16 @@
-- A simple continuous query.
set schema iot;
-create stream table stream_tmp (t timestamp, sensor integer, val decimal(8,2))
;
-create table result(like stream_tmp);
+create stream table stmp (t timestamp, sensor integer, val decimal(8,2)) ;
+create table result(like stmp);
create procedure cq00()
begin
- insert into result select min(t), count(*), avg(val) from stream_tmp;
+ insert into result select min(t), count(*), avg(val) from stmp;
end;
call iot.query('iot','cq00');
-call iot.query('insert into iot.result select min(t), count(*), avg(val) from
iot.stream_tmp;');
+call iot.query('insert into iot.result select min(t), count(*), avg(val) from
iot.stmp;');
select * from iot.baskets();
select * from iot.queries();
@@ -20,11 +20,14 @@ select * from iot.outputplaces();
-- stop all continuous queries
call iot.deactivate();
-insert into stream_tmp values('2005-09-23 12:34:26.736',1,12.34);
-select * from stream_tmp;
+insert into stmp values('2005-09-23 12:34:26.736',1,12.34);
+select * from stmp;
-- reactivate all continuous queries
call iot.activate();
+
+-- wait until the scheduler handled them
+select * from iot.queries();
select * from result;
select * from iot.baskets();
diff --git a/sql/backends/monet5/iot/Tests/iot05.sql
b/sql/backends/monet5/iot/Tests/iot05.sql
--- a/sql/backends/monet5/iot/Tests/iot05.sql
+++ b/sql/backends/monet5/iot/Tests/iot05.sql
@@ -1,6 +1,5 @@
-- introduce a heartbeat query
set schema iot;
-set optimizer='iot_pipe';
declare hbclk1 integer;
declare hbclk2 integer;
@@ -23,7 +22,7 @@ create procedure clk3()
begin
set hbclk1 = hbclk1+1;
set hbclk1 = hbclk1+1;
- --set cnt =(select count(*) from stream_tmp);
+ --set cnt =(select count(*) from stmp);
end;
-- alternative is a simple query
_______________________________________________
checkin-list mailing list
[email protected]
https://www.monetdb.org/mailman/listinfo/checkin-list