Changeset: 69036e186fd1 for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=69036e186fd1
Added Files:
        monetdb5/scheduler/Tests/20Runs3200MB64MB_9999_9.mal
Branch: mutation
Log Message:

join select 3200MB 64MB 50% selectivity test script


diffs (76 lines):

diff --git a/monetdb5/scheduler/Tests/20Runs3200MB64MB_9999_9.mal 
b/monetdb5/scheduler/Tests/20Runs3200MB64MB_9999_9.mal
new file mode 100644
--- /dev/null
+++ b/monetdb5/scheduler/Tests/20Runs3200MB64MB_9999_9.mal
@@ -0,0 +1,71 @@
+function initializeLeft{unsafe}():bat[:oid,:lng];
+
+       b:bat[:oid,:lng] := bat.load("Left3200MB");
+       bat.setTransient(b);
+
+       cnt := aggr.count(b);
+       io.printf("\nLeft count %d\n",cnt);
+
+        return b;
+end initializeLeft;
+
+function initializeRight{unsafe}():bat[:oid,:lng];
+
+       b:bat[:oid,:lng] := bat.load("Right64MB");
+       bat.setTransient(b);
+
+       cnt := aggr.count(b);
+       io.printf("\nRight count %d\n",cnt);
+
+        return b;
+end initializeRight;
+
+function query(a:bat[:oid,:lng],b:bat[:oid,:lng]):lng;
+        profiler.activate("ticks");
+        profiler.activate("thread");
+        profiler.activate("stmt");
+        profiler.activate("time");
+        profiler.setAll();
+       # profiler.start();
+
+        t0:= alarm.usec();
+
+barrier z:= language.dataflow();
+        a1 := algebra.subselect(a,1:lng,999999999:lng,true,true,false);
+       c1 := algebra.leftfetchjoin(a1, a);
+        (s1,s2) := algebra.join(c1,b);
+
+exit z;
+        t1:= alarm.usec();
+
+       stmt:= profiler.getTrace("stmt");
+       ticks:= profiler.getTrace("ticks");
+       thread:= profiler.getTrace("thread");
+       time1:= profiler.getTrace("time");
+       # io.print(time1,thread,ticks,stmt);
+       # profiler.stop();
+
+       return query := t1-t0;
+end query;
+
+optimizer.multicore("user","query");
+function testrun();
+        a:= initializeLeft();
+        bat.setReadMode(a);
+        b:= initializeRight();
+        bat.setReadMode(b);
+
+#       profiler.activate("ISTestmrw");
+#       profiler.setAll();
+#       profiler.openStream();
+#       profiler.start();
+
+barrier step:=0;
+       t2:= user.query(a,b);
+        io.printf("@ %d %d\n",step,t2);
+        redo step:= iterator.next(1,40);
+exit step;
+#       profiler.stop();
+end testrun;
+
+testrun();
_______________________________________________
checkin-list mailing list
checkin-list@monetdb.org
http://mail.monetdb.org/mailman/listinfo/checkin-list

Reply via email to