MonetDB: default - Intermittent commit

[mk]

Changeset: 0a26dd792713 for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=0a26dd792713
Modified Files:
        sql/backends/monet5/datacell/Tests/poc.sql
        sql/backends/monet5/datacell/Tests/proof.sql
        sql/backends/monet5/datacell/datacell.sql
Branch: default
Log Message:

Intermittent commit
Try to get all compile again.


diffs (100 lines):

diff --git a/sql/backends/monet5/datacell/Tests/proof.sql 
b/sql/backends/monet5/datacell/Tests/poc.sql
rename from sql/backends/monet5/datacell/Tests/proof.sql
rename to sql/backends/monet5/datacell/Tests/poc.sql
--- a/sql/backends/monet5/datacell/Tests/proof.sql
+++ b/sql/backends/monet5/datacell/Tests/poc.sql
@@ -1,29 +1,44 @@
--- A straw-man's datacell 
+-- A straw-man's datacell proof of concept implementation
 -- This example relies on the standard SQL facilities
 -- to demonstrate the DataCell functionality.
 -- The specific runtime issues are handled by an optimizer
 
-create table basket_X(
+create schema datacell;
+
+create table datacell.basket_X(
     id integer auto_increment,
     tag timestamp default now(),
     payload integer
 );
 
--- empty the basket
-create function basket_X()
+-- to be used by continous queries
+create function datacell.basket_X()
 returns table (id integer, tag timestamp, payload integer)
 begin
        return select * from basket_X;
 end;
 
--- initialize and start the receptor for basket X
-create procedure receptor_X()
+-- to be used by receptor thread
+create function datacell.receptor_X()
+returns boolean
 begin
-       call receptor('localhost:50100','start');
-       insert into basket_X(tag,payload) values ( now(), receptor_int(0));
+       insert into basket_X(payload) values ( 1);
+       return true;
 end;
 
-create table basket_Y( id integer);
+call register_basket('basket_x');
+call register_receptor('receptor_x','localhost:50100');
+call start_receptor('receptor_x');
+
+create table basket_Y( etag timestamp, like basket_X);
+
+-- the continues query is registered and started
+create procedure query_X_Y()
+begin
+       insert into basket_Y select now(), *  from basket_X() ;
+end;
+call register_query('query_X_Y');
+call start_query('query_X_Y');
 
 create function basket_Y()
 returns table (id integer)
@@ -31,16 +46,13 @@
        return select * from basket_Y;
 end;
 
-
-create procedure cquery_pass()
+-- sent it over the wire.
+create function emitter_Y()
+returns boolean;
 begin
-       insert into basket_Y(id) select id from basket_X() ;
+       select * from basket_Y();
+       return true;
 end;
-
-
--- sent it over the wire.
-create procedure emitter_Y()
-begin
-       call emitter('localhost:50100','start');
-       call emitter(select * from basket_Y());
-end;
+call register_basket('basket_y');
+call register_emitter('emitter_y','localhost:50101');
+call start_emitter('emitter_y');
diff --git a/sql/backends/monet5/datacell/datacell.sql 
b/sql/backends/monet5/datacell/datacell.sql
--- a/sql/backends/monet5/datacell/datacell.sql
+++ b/sql/backends/monet5/datacell/datacell.sql
@@ -19,10 +19,6 @@
     external name datacell.receptor_action;
 
 -- MonetDB tuple formatted message field extractors
-create function receptor_int(col int) 
-returns int
-external name datacell.receptor_int;
+create procedure datacell.register_basket(s string)
+external name datacell.register_basket;
 
-create function receptor_str(col int) 
-returns str
-external name datacell.receptor_str;
_______________________________________________
Checkin-list mailing list
Checkin-list@monetdb.org
http://mail.monetdb.org/mailman/listinfo/checkin-list