Changeset: cc0346bb7f7e for MonetDB URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=cc0346bb7f7e Removed Files: monetdb5/scheduler/Tests/queryJoin.mal monetdb5/scheduler/Tests/queryJoinShort.mal monetdb5/scheduler/Tests/querySelect.mal Branch: mutation Log Message:
old mal files deleted diffs (228 lines): diff --git a/monetdb5/scheduler/Tests/queryJoin.mal b/monetdb5/scheduler/Tests/queryJoin.mal deleted file mode 100644 --- a/monetdb5/scheduler/Tests/queryJoin.mal +++ /dev/null @@ -1,85 +0,0 @@ -# example framework for a multicore based execution stack -# illustrate how it would appear after an optimizer call. - -function initializeFirst{unsafe}():bat[:oid,:lng]; - b:= bat.new(:oid,:lng); - - r:= mmath.srand(0); - barrier i:= 0:lng; - k:= mmath.rand(); - l:= calc.lng(k); - bat.append(b,l); - redo i:= iterator.next(1:lng,1000000:lng); - exit i; - - return b; -end initializeFirst; - -function initializeNext{unsafe}():bat[:oid,:lng]; - b:= bat.new(:oid,:lng); - - r:= mmath.srand(0); - barrier i:= 0:lng; - k:= mmath.rand(); - l:= calc.lng(k); - bat.append(b,l); - redo i:= iterator.next(1:lng,1000000:lng); - exit i; - - return b; -end initializeNext; - - -function query(run:int, a:bat[:oid,:lng], b:bat[:oid,:lng]); - t0:= alarm.usec(); - - profiler.activate("ticks"); - profiler.activate("thread"); - profiler.activate("stmt"); - profiler.setAll(); - profiler.start(); - -barrier z:= language.dataflow(); - (s1,s2) := algebra.join(a,b); -exit z; - t1:= alarm.usec(); - t2 := t1-t0; - io.printf("#run %d %d\n",run,t2); - stmt:= profiler.getTrace("stmt"); - ticks:= profiler.getTrace("ticks"); - thread:= profiler.getTrace("thread"); - io.print(thread,ticks,stmt); - -end query; - -optimizer.multicore("user","query"); -function testrun(); - - a:= initializeFirst(); - bat.setReadMode(a); - b:= initializeNext(); - bat.setReadMode(b); - user.query(0,a,b); - user.query(1,a,b); - user.query(2,a,b); - user.query(3,a,b); - user.query(4,a,b); - user.query(5,a,b); - user.query(6,a,b); - user.query(7,a,b); - user.query(8,a,b); - user.query(9,a,b); - user.query(10,a,b); - user.query(11,a,b); - user.query(12,a,b); - user.query(13,a,b); - user.query(14,a,b); - user.query(15,a,b); - user.query(16,a,b); - user.query(17,a,b); - user.query(18,a,b); - user.query(19,a,b); - user.query(20,a,b); - -end testrun; -testrun(); diff --git a/monetdb5/scheduler/Tests/queryJoinShort.mal b/monetdb5/scheduler/Tests/queryJoinShort.mal deleted file mode 100644 --- a/monetdb5/scheduler/Tests/queryJoinShort.mal +++ /dev/null @@ -1,72 +0,0 @@ -function initializeFirst{unsafe}():bat[:oid,:lng]; - b:= bat.new(:oid,:lng); - k := 0:lng; - barrier i:= 0:lng; - k:= k+1; - l:= calc.lng(k); - bat.append(b,l); - redo i:= iterator.next(1:lng,4:lng); - exit i; - io.print(b); - - return b; -end initializeFirst; - -function initializeNext{unsafe}():bat[:oid,:lng]; - b:= bat.new(:oid,:lng); - k := 1:lng; - barrier i:= 0:lng; - k:= 2:lng; - l:= calc.lng(k); - bat.append(b,l); - redo i:= iterator.next(1:lng,4:lng); - exit i; - io.print(b); - - return b; -end initializeNext; - - -function query(run:int, a:bat[:oid,:lng], b:bat[:oid,:lng]); - t0:= alarm.usec(); - sql.init(); -barrier z:= language.dataflow(); - (s1,s2) := algebra.join(a,b); - io.print(s1); -# X_46 := sql.resultSet(1,1,s1); -# X_53 := io.stdout(); -# sql.exportResult(X_53,X_46); -exit z; - t1:= alarm.usec(); - t2 := t1-t0; - io.printf("#run %d %d\n",run,t2); -end query; - -optimizer.multicore("user","query"); -function testrun(); - - a:= initializeFirst(); - b:= initializeNext(); - user.query(0,a,b); -# user.query(1,a,b); -# user.query(2,a,b); -# user.query(3,a,b); -# user.query(4,a,b); -# user.query(5,a,b); -# user.query(6,a,b); -# user.query(7,a,b); -# user.query(8,a,b); -# user.query(9,a,b); -# user.query(10,a,b); -# user.query(11,a,b); -# user.query(12,a,b); -# user.query(13,a,b); -# user.query(14,a,b); -# user.query(15,a,b); -# user.query(16,a,b); -# user.query(17,a,b); -# user.query(18,a,b); -# user.query(19,a,b); -# user.query(20,a,b); -end testrun; -testrun(); diff --git a/monetdb5/scheduler/Tests/querySelect.mal b/monetdb5/scheduler/Tests/querySelect.mal deleted file mode 100644 --- a/monetdb5/scheduler/Tests/querySelect.mal +++ /dev/null @@ -1,56 +0,0 @@ -# example framework for a multicore based execution stack -# illustrate how it would appear after an optimizer call. - -function initialize{unsafe}():bat[:oid,:lng]; - b:= bat.new(:oid,:lng); - - r:= mmath.srand(0); - barrier i:= 0:lng; - k:= mmath.rand(); - l:= calc.lng(k); - bat.append(b,l); - redo i:= iterator.next(1:lng,1000000:lng); - exit i; - - return b; -end initialize; - -function query(run:int, b:bat[:oid,:lng]); - t0:= alarm.usec(); -barrier z:= language.dataflow(); - s1 := algebra.subselect(b,1:lng,99:lng,true,false,false); - #s2 := algebra.subselect(b,1:lng,999:lng,true,false,false); - #s3 := algebra.subselect(b,1:lng,9999:lng, true,false,false); -exit z; - t1:= alarm.usec(); - t2 := t1-t0; - io.printf("#run %d %d\n",run,t2); -end query; - -optimizer.multicore("user","query"); -function testrun(); - b:= initialize(); - user.query(0,b); - user.query(1,b); - user.query(2,b); - user.query(3,b); - user.query(4,b); - user.query(5,b); - user.query(6,b); - user.query(7,b); - user.query(8,b); - user.query(9,b); - user.query(10,b); - user.query(11,b); - user.query(12,b); - user.query(13,b); - user.query(14,b); - user.query(15,b); - user.query(16,b); - user.query(17,b); - user.query(18,b); - user.query(19,b); - user.query(20,b); -end testrun; -testrun(); - _______________________________________________ checkin-list mailing list checkin-list@monetdb.org http://mail.monetdb.org/mailman/listinfo/checkin-list