[snee] r1369 committed - fixed codnor inputs, fixed aggregation tuple calculator
0 views
Skip to first unread message
sn...@googlecode.com
Mar 6, 2013, 12:22:16 PM3/6/13
to snee-...@googlegroups.com
Revision: 1369
Author: alan.bar...@gmail.com
Date: Wed Mar 6 09:21:27 2013
Log: fixed codnor inputs, fixed aggregation tuple calculator
http://code.google.com/p/snee/source/detail?r=1369
Added:
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/submit.txt
Modified:
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/java/uk/ac/manchester/snee/client/RelibaleChannelClient.java
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/java/uk/ac/manchester/snee/client/utils/CondorScriptGenerator.java
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/java/uk/ac/manchester/snee/client/utils/collateResults.java
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.2.xml
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.3.xml
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.4.xml
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.5.xml
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.2.properties
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.3.properties
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.4.properties
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.5.properties
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/top60.4.xml
/branches/alan_2012_07_19_unreliableChannels/snee-wsn-manager/src/main/java/uk/ac/manchester/cs/snee/manager/executer/Executer.java
/branches/alan_2012_07_19_unreliableChannels/snee-wsn-manager/src/main/java/uk/ac/manchester/cs/snee/manager/planner/costbenifitmodel/model/channel/ChannelModelSite.java
=======================================
--- /dev/null
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/submit.txt
Wed Mar 6 09:21:27 2013
@@ -0,0 +1,10415 @@
+universe = vanilla
+executable = start.sh
+when_to_transfer_output = ON_EXIT
+Should_Transfer_Files = YES
+transfer_input_files = ../SNEE.jar,../jre.tar.gz
+Requirements = (OpSys == "LINUX")
+Request_Disk = 3000000
+request_memory = 2048
+#Output = output$(Process).txt
+#Error = error$(Process).txt
+log = log.txt
+Output = out.txt
+Error = err.txt
+notification = error
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.2.properties 1 0 1
+initialdir = query1.2.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.2.properties 1 0 0.8
+initialdir = query1.2.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.2.properties 1 0 0.6
+initialdir = query1.2.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.2.properties 1 0 0.4
+initialdir = query1.2.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.2.properties 1 0 0.2
+initialdir = query1.2.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.3.properties 1 0 1
+initialdir = query1.3.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.3.properties 1 0 0.8
+initialdir = query1.3.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.3.properties 1 0 0.6
+initialdir = query1.3.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.3.properties 1 0 0.4
+initialdir = query1.3.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.3.properties 1 0 0.2
+initialdir = query1.3.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.4.properties 1 0 1
+initialdir = query1.4.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.4.properties 1 0 0.8
+initialdir = query1.4.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.4.properties 1 0 0.6
+initialdir = query1.4.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.4.properties 1 0 0.4
+initialdir = query1.4.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.4.properties 1 0 0.2
+initialdir = query1.4.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.5.properties 1 0 1
+initialdir = query1.5.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.5.properties 1 0 0.8
+initialdir = query1.5.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.5.properties 1 0 0.6
+initialdir = query1.5.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.5.properties 1 0 0.4
+initialdir = query1.5.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.5.properties 1 0 0.2
+initialdir = query1.5.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.2.properties 2 0 1
+initialdir = query2.2.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.2.properties 2 0 0.8
+initialdir = query2.2.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.2.properties 2 0 0.6
+initialdir = query2.2.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.2.properties 2 0 0.4
+initialdir = query2.2.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.2.properties 2 0 0.2
+initialdir = query2.2.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.3.properties 2 0 1
+initialdir = query2.3.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.3.properties 2 0 0.8
+initialdir = query2.3.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.3.properties 2 0 0.6
+initialdir = query2.3.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.3.properties 2 0 0.4
+initialdir = query2.3.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.3.properties 2 0 0.2
+initialdir = query2.3.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.4.properties 2 0 1
+initialdir = query2.4.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.4.properties 2 0 0.8
+initialdir = query2.4.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.4.properties 2 0 0.6
+initialdir = query2.4.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.4.properties 2 0 0.4
+initialdir = query2.4.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.4.properties 2 0 0.2
+initialdir = query2.4.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.5.properties 2 0 1
+initialdir = query2.5.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.5.properties 2 0 0.8
+initialdir = query2.5.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.5.properties 2 0 0.6
+initialdir = query2.5.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.5.properties 2 0 0.4
+initialdir = query2.5.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.5.properties 2 0 0.2
+initialdir = query2.5.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.2.properties 3 0 1
+initialdir = query3.2.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.2.properties 3 0 0.8
+initialdir = query3.2.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.2.properties 3 0 0.6
+initialdir = query3.2.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.2.properties 3 0 0.4
+initialdir = query3.2.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.2.properties 3 0 0.2
+initialdir = query3.2.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.3.properties 3 0 1
+initialdir = query3.3.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.3.properties 3 0 0.8
+initialdir = query3.3.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.3.properties 3 0 0.6
+initialdir = query3.3.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.3.properties 3 0 0.4
+initialdir = query3.3.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.3.properties 3 0 0.2
+initialdir = query3.3.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.4.properties 3 0 1
+initialdir = query3.4.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.4.properties 3 0 0.8
+initialdir = query3.4.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.4.properties 3 0 0.6
+initialdir = query3.4.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.4.properties 3 0 0.4
+initialdir = query3.4.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.4.properties 3 0 0.2
+initialdir = query3.4.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.5.properties 3 0 1
+initialdir = query3.5.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.5.properties 3 0 0.8
+initialdir = query3.5.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.5.properties 3 0 0.6
+initialdir = query3.5.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.5.properties 3 0 0.4
+initialdir = query3.5.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.5.properties 3 0 0.2
+initialdir = query3.5.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.2.properties 4 0 1
+initialdir = query4.2.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.2.properties 4 0 0.8
+initialdir = query4.2.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.2.properties 4 0 0.6
+initialdir = query4.2.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.2.properties 4 0 0.4
+initialdir = query4.2.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.2.properties 4 0 0.2
+initialdir = query4.2.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.3.properties 4 0 1
+initialdir = query4.3.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.3.properties 4 0 0.8
+initialdir = query4.3.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.3.properties 4 0 0.6
+initialdir = query4.3.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.3.properties 4 0 0.4
+initialdir = query4.3.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.3.properties 4 0 0.2
+initialdir = query4.3.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.4.properties 4 0 1
+initialdir = query4.4.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.4.properties 4 0 0.8
+initialdir = query4.4.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.4.properties 4 0 0.6
+initialdir = query4.4.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.4.properties 4 0 0.4
+initialdir = query4.4.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.4.properties 4 0 0.2
+initialdir = query4.4.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.5.properties 4 0 1
+initialdir = query4.5.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.5.properties 4 0 0.8
+initialdir = query4.5.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.5.properties 4 0 0.6
+initialdir = query4.5.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.5.properties 4 0 0.4
+initialdir = query4.5.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.5.properties 4 0 0.2
+initialdir = query4.5.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.2.properties 5 0 1
+initialdir = query5.2.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.2.properties 5 0 0.8
+initialdir = query5.2.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.2.properties 5 0 0.6
+initialdir = query5.2.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.2.properties 5 0 0.4
+initialdir = query5.2.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.2.properties 5 0 0.2
+initialdir = query5.2.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.3.properties 5 0 1
+initialdir = query5.3.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.3.properties 5 0 0.8
+initialdir = query5.3.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.3.properties 5 0 0.6
+initialdir = query5.3.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.3.properties 5 0 0.4
+initialdir = query5.3.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.3.properties 5 0 0.2
+initialdir = query5.3.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.4.properties 5 0 1
+initialdir = query5.4.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.4.properties 5 0 0.8
+initialdir = query5.4.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.4.properties 5 0 0.6
+initialdir = query5.4.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.4.properties 5 0 0.4
+initialdir = query5.4.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.4.properties 5 0 0.2
+initialdir = query5.4.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.5.properties 5 0 1
+initialdir = query5.5.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.5.properties 5 0 0.8
+initialdir = query5.5.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.5.properties 5 0 0.6
+initialdir = query5.5.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.5.properties 5 0 0.4
+initialdir = query5.5.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.5.properties 5 0 0.2
+initialdir = query5.5.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.2.properties 6 0 1
+initialdir = query6.2.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.2.properties 6 0 0.8
+initialdir = query6.2.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.2.properties 6 0 0.6
+initialdir = query6.2.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.2.properties 6 0 0.4
+initialdir = query6.2.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.2.properties 6 0 0.2
+initialdir = query6.2.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.3.properties 6 0 1
+initialdir = query6.3.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.3.properties 6 0 0.8
+initialdir = query6.3.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.3.properties 6 0 0.6
+initialdir = query6.3.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.3.properties 6 0 0.4
+initialdir = query6.3.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.3.properties 6 0 0.2
+initialdir = query6.3.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.4.properties 6 0 1
+initialdir = query6.4.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.4.properties 6 0 0.8
+initialdir = query6.4.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.4.properties 6 0 0.6
+initialdir = query6.4.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.4.properties 6 0 0.4
+initialdir = query6.4.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.4.properties 6 0 0.2
+initialdir = query6.4.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.5.properties 6 0 1
+initialdir = query6.5.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.5.properties 6 0 0.8
+initialdir = query6.5.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.5.properties 6 0 0.6
+initialdir = query6.5.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.5.properties 6 0 0.4
+initialdir = query6.5.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.5.properties 6 0 0.2
+initialdir = query6.5.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.2.properties 60 0 1
+initialdir = query60.2.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.2.properties 60 0 0.8
+initialdir = query60.2.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.2.properties 60 0 0.6
+initialdir = query60.2.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.2.properties 60 0 0.4
+initialdir = query60.2.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.2.properties 60 0 0.2
+initialdir = query60.2.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.3.properties 60 0 1
+initialdir = query60.3.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.3.properties 60 0 0.8
+initialdir = query60.3.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.3.properties 60 0 0.6
+initialdir = query60.3.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.3.properties 60 0 0.4
+initialdir = query60.3.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.3.properties 60 0 0.2
+initialdir = query60.3.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.4.properties 60 0 1
+initialdir = query60.4.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.4.properties 60 0 0.8
+initialdir = query60.4.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.4.properties 60 0 0.6
+initialdir = query60.4.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.4.properties 60 0 0.4
+initialdir = query60.4.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.4.properties 60 0 0.2
+initialdir = query60.4.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.5.properties 60 0 1
+initialdir = query60.5.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.5.properties 60 0 0.8
+initialdir = query60.5.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.5.properties 60 0 0.6
+initialdir = query60.5.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.5.properties 60 0 0.4
+initialdir = query60.5.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.5.properties 60 0 0.2
+initialdir = query60.5.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.2.properties 62 0 1
+initialdir = query62.2.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.2.properties 62 0 0.8
+initialdir = query62.2.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.2.properties 62 0 0.6
+initialdir = query62.2.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.2.properties 62 0 0.4
+initialdir = query62.2.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.2.properties 62 0 0.2
+initialdir = query62.2.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.3.properties 62 0 1
+initialdir = query62.3.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.3.properties 62 0 0.8
+initialdir = query62.3.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.3.properties 62 0 0.6
+initialdir = query62.3.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.3.properties 62 0 0.4
+initialdir = query62.3.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.3.properties 62 0 0.2
+initialdir = query62.3.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.4.properties 62 0 1
+initialdir = query62.4.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.4.properties 62 0 0.8
+initialdir = query62.4.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.4.properties 62 0 0.6
+initialdir = query62.4.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.4.properties 62 0 0.4
+initialdir = query62.4.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.4.properties 62 0 0.2
+initialdir = query62.4.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.5.properties 62 0 1
+initialdir = query62.5.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.5.properties 62 0 0.8
+initialdir = query62.5.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.5.properties 62 0 0.6
+initialdir = query62.5.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.5.properties 62 0 0.4
+initialdir = query62.5.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.5.properties 62 0 0.2
+initialdir = query62.5.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.2.properties 64 0 1
+initialdir = query64.2.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.2.properties 64 0 0.8
+initialdir = query64.2.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.2.properties 64 0 0.6
+initialdir = query64.2.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.2.properties 64 0 0.4
+initialdir = query64.2.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.2.properties 64 0 0.2
+initialdir = query64.2.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.3.properties 64 0 1
+initialdir = query64.3.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.3.properties 64 0 0.8
+initialdir = query64.3.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.3.properties 64 0 0.6
+initialdir = query64.3.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.3.properties 64 0 0.4
+initialdir = query64.3.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.3.properties 64 0 0.2
+initialdir = query64.3.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.4.properties 64 0 1
+initialdir = query64.4.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.4.properties 64 0 0.8
+initialdir = query64.4.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.4.properties 64 0 0.6
+initialdir = query64.4.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.4.properties 64 0 0.4
+initialdir = query64.4.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.4.properties 64 0 0.2
+initialdir = query64.4.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.5.properties 64 0 1
+initialdir = query64.5.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.5.properties 64 0 0.8
+initialdir = query64.5.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.5.properties 64 0 0.6
+initialdir = query64.5.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.5.properties 64 0 0.4
+initialdir = query64.5.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.5.properties 64 0 0.2
+initialdir = query64.5.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.2.properties 67 0 1
+initialdir = query67.2.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.2.properties 67 0 0.8
+initialdir = query67.2.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.2.properties 67 0 0.6
+initialdir = query67.2.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.2.properties 67 0 0.4
+initialdir = query67.2.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.2.properties 67 0 0.2
+initialdir = query67.2.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.3.properties 67 0 1
+initialdir = query67.3.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.3.properties 67 0 0.8
+initialdir = query67.3.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.3.properties 67 0 0.6
+initialdir = query67.3.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.3.properties 67 0 0.4
+initialdir = query67.3.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.3.properties 67 0 0.2
+initialdir = query67.3.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.4.properties 67 0 1
+initialdir = query67.4.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.4.properties 67 0 0.8
+initialdir = query67.4.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.4.properties 67 0 0.6
+initialdir = query67.4.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.4.properties 67 0 0.4
+initialdir = query67.4.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.4.properties 67 0 0.2
+initialdir = query67.4.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.5.properties 67 0 1
+initialdir = query67.5.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.5.properties 67 0 0.8
+initialdir = query67.5.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.5.properties 67 0 0.6
+initialdir = query67.5.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.5.properties 67 0 0.4
+initialdir = query67.5.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.5.properties 67 0 0.2
+initialdir = query67.5.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.2.properties 68 0 1
+initialdir = query68.2.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.2.properties 68 0 0.8
+initialdir = query68.2.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.2.properties 68 0 0.6
+initialdir = query68.2.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.2.properties 68 0 0.4
+initialdir = query68.2.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.2.properties 68 0 0.2
+initialdir = query68.2.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.3.properties 68 0 1
+initialdir = query68.3.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.3.properties 68 0 0.8
+initialdir = query68.3.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.3.properties 68 0 0.6
+initialdir = query68.3.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.3.properties 68 0 0.4
+initialdir = query68.3.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.3.properties 68 0 0.2
+initialdir = query68.3.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.4.properties 68 0 1
+initialdir = query68.4.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.4.properties 68 0 0.8
+initialdir = query68.4.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.4.properties 68 0 0.6
+initialdir = query68.4.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.4.properties 68 0 0.4
+initialdir = query68.4.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.4.properties 68 0 0.2
+initialdir = query68.4.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.5.properties 68 0 1
+initialdir = query68.5.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.5.properties 68 0 0.8
+initialdir = query68.5.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.5.properties 68 0 0.6
+initialdir = query68.5.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.5.properties 68 0 0.4
+initialdir = query68.5.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.5.properties 68 0 0.2
+initialdir = query68.5.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.2.properties 69 0 1
+initialdir = query69.2.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.2.properties 69 0 0.8
+initialdir = query69.2.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.2.properties 69 0 0.6
+initialdir = query69.2.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.2.properties 69 0 0.4
+initialdir = query69.2.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.2.properties 69 0 0.2
+initialdir = query69.2.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.3.properties 69 0 1
+initialdir = query69.3.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.3.properties 69 0 0.8
+initialdir = query69.3.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.3.properties 69 0 0.6
+initialdir = query69.3.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.3.properties 69 0 0.4
+initialdir = query69.3.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.3.properties 69 0 0.2
+initialdir = query69.3.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.4.properties 69 0 1
+initialdir = query69.4.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.4.properties 69 0 0.8
+initialdir = query69.4.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.4.properties 69 0 0.6
+initialdir = query69.4.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.4.properties 69 0 0.4
+initialdir = query69.4.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.4.properties 69 0 0.2
+initialdir = query69.4.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.5.properties 69 0 1
+initialdir = query69.5.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.5.properties 69 0 0.8
+initialdir = query69.5.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.5.properties 69 0 0.6
+initialdir = query69.5.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.5.properties 69 0 0.4
+initialdir = query69.5.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.5.properties 69 0 0.2
+initialdir = query69.5.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee70.2.properties 70 0 1
+initialdir = query70.2.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee70.2.properties 70 0 0.8
+initialdir = query70.2.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee70.2.properties 70 0 0.6
+initialdir = query70.2.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee70.2.properties 70 0 0.4
+initialdir = query70.2.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee70.2.properties 70 0 0.2
+initialdir = query70.2.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee70.3.properties 70 0 1
+initialdir = query70.3.0.1
+queue
***The diff for this file has been truncated for email.***
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/java/uk/ac/manchester/snee/client/RelibaleChannelClient.java
Mon Mar 4 09:34:19 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/java/uk/ac/manchester/snee/client/RelibaleChannelClient.java
Wed Mar 6 09:21:27 2013
@@ -40,7 +40,7 @@
{
private static String sep = System.getProperty("file.separator");
- private static int queryid =1;
+ private static int queryid =30;
protected static int testNo = 1;
protected static int kResil = 2;
private static int max = 90;
@@ -216,8 +216,8 @@
// {
//get query & schemas
// String currentQuery = queryIterator.next();
- // String currentQuery = "SELECT RSTREAM AVG(anow.x) as qx FROM A[NOW]
anow ;";
- String currentQuery = "SELECT RSTREAM anow.x as qx FROM A[NOW] anow ;";
+ String currentQuery = "SELECT RSTREAM AVG(anow.x) as qx FROM A[NOW]
anow ;";
+ // String currentQuery = "SELECT RSTREAM anow.x as qx FROM A[NOW]
anow ;";
// String currentQuery = "SELECT RSTREAM anow.x as qx FROM A[NOW]
anow,(SELECT bnow.x as sq1x FROM B[NOW] bnow, C[NOW] cnow WHERE
bnow.x=cnow.x) sq1 WHERE anow.x=sq1.sq1x;";
// String currentQuery = "SELECT RSTREAM sq1.sq1x as qx FROM (SELECT
anow.x as sq1x FROM A[NOW] anow, B[NOW] bnow WHERE anow.x=bnow.x) sq1,
(SELECT cnow.x as sq2x FROM C[NOW] cnow, D[NOW] dnow WHERE cnow.x=dnow.x)
sq2 WHERE sq1.sq1x=sq2.sq2x;";
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/java/uk/ac/manchester/snee/client/utils/CondorScriptGenerator.java
Fri Mar 1 10:09:26 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/java/uk/ac/manchester/snee/client/utils/CondorScriptGenerator.java
Wed Mar 6 09:21:27 2013
@@ -25,7 +25,7 @@
public static void main(String[] args)
{
-
+ //possible ids are 1,2,3,4,5,6,30,31,32,33,34,36,60,62,64,67,68
seeds.add(new Long(0));
seeds.add(new Long(1));
seeds.add(new Long(10));
@@ -36,7 +36,7 @@
seeds.add(new Long(35));
seeds.add(new Long(40));
seeds.add(new Long(45));
- validIds.addAll(Arrays.asList(30,31,32,33,34,36));
+
validIds.addAll(Arrays.asList(1,2,3,4,5,6,30,31,32,33,34,36,60,62,64,67,68));
File condorFile = new File("condor");
if(!condorFile.exists())
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/java/uk/ac/manchester/snee/client/utils/collateResults.java
Fri Mar 1 10:09:26 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/java/uk/ac/manchester/snee/client/utils/collateResults.java
Wed Mar 6 09:21:27 2013
@@ -1,443 +0,0 @@
-package uk.ac.manchester.snee.client.utils;
-
-import java.io.BufferedReader;
-import java.io.BufferedWriter;
-import java.io.File;
-import java.io.FileReader;
-import java.io.FileWriter;
-import java.io.IOException;
-import java.text.DecimalFormat;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.Iterator;
-
-import uk.ac.manchester.cs.snee.compiler.costmodels.HashMapList;
-
-public class collateResults
-{
-
- private static String sep = System.getProperty("file.separator");
-
- public static void main(String [] args)
- {
- try
- {
- File root = new File("/local/BigSubmit");
- HashMap<String, Query> data = new HashMap<String, Query>();
- File[] listedFiles = root.listFiles();
- int max = listedFiles.length;
- for(int counter = 0; counter < max; counter++)
- {
- File folder = listedFiles[counter];
- if(folder.isDirectory())
- {
- String[] firstBits = folder.toString().split("/");
- String fileName = firstBits[firstBits.length -1];
-
- // Process extractor = Runtime.getRuntime().exec(new String("tar
-xf /local/BigSubmit/" + fileName + "/output.tgz"));
- // extractor.waitFor();
-
- String[] bits = fileName.split("\\.");
- File outputTuplesFile = null;
- if(bits.length == 4)
- {
- outputTuplesFile = new File(folder.toString() + sep
+ "output/" + bits[0] + sep+
- "AutonomicManData" + sep
+ "executer" + sep +
- "1.0" + sep + "tupleOutput");
- }
- else
- {
- outputTuplesFile = new File(folder.toString() + sep
+ "output/" + bits[0] + sep +
- "AutonomicManData" + sep
+ "executer" + sep + bits[3] +
- "." + bits[4] + sep
+ "tupleOutput");
- }
- if(outputTuplesFile.exists())
- {
- BufferedReader in = new BufferedReader(new
FileReader(outputTuplesFile));
- ArrayList<String> tuples = locateCorrectArrayList(data, bits);
- System.out.println("reading in file for "+ bits[0]);
- readInData(in, tuples);
- in.close();
- }
- }
- }
-
- System.out.println("starting output");
- outputData(data);
- }
- catch(Exception e)
- {
- System.out.println(e.getMessage());
- e.printStackTrace();
- }
- }
-
- private static void outputData( HashMap<String, Query> data)
- throws IOException
- {
- HashMap<String, Query> averagedData = new HashMap<String, Query>();
- File distanceOutput = null;
- File output = new File("/local/BigSubmit/output");
- output.mkdir();
- Iterator<String> queryKeys = data.keySet().iterator();
- while(queryKeys.hasNext())
- {
- String queryKey = queryKeys.next();
- Query query = new Query(new HashMap<String, Distance>());
- averagedData.put(queryKey, query);
- File queryOutput = new File(output.toString() + sep + queryKey);
- queryOutput.mkdir();
- HashMap<String, Distance> distances = data.get(queryKey).getData();
- Iterator<String> distanceKeys = distances.keySet().iterator();
- while(distanceKeys.hasNext())
- {
- String distanceKey = distanceKeys.next();
- Distance d = new Distance(new HashMap<String, Klevel>());
- query.getData().put(distanceKey, d);
- distanceOutput = new File(queryOutput.toString() + sep +
distanceKey);
- distanceOutput.mkdir();
- HashMap<String, Klevel> kLevels =
distances.get(distanceKey).getData();
- Iterator<String> klevelKeys = kLevels.keySet().iterator();
- while(klevelKeys.hasNext())
- {
- String kKey = klevelKeys.next();
- Klevel k = new Klevel(new HashMap<String, Seed>());
- d.getData().put(kKey, k);
- absorbSeeds(kKey, kLevels, distanceOutput, k);
- }
- }
- }
- data = null;
- queryKeys = averagedData.keySet().iterator();
- while(queryKeys.hasNext())
- {
- String queryKey = queryKeys.next();
- File queryOutput = new File(output.toString() + sep + queryKey);
- HashMap<String, Distance> distances =
averagedData.get(queryKey).getData();
- Iterator<String> distanceKeys = distances.keySet().iterator();
- while(distanceKeys.hasNext())
- {
- String distanceKey = distanceKeys.next();
- distanceOutput = new File(queryOutput.toString() + sep +
distanceKey);
- HashMap<String, Klevel> kLevels =
distances.get(distanceKey).getData();
- outputAveragedKLevel(kLevels, distanceOutput);
- }
- }
-
-
- }
-
- private static void absorbSeeds(String kKey, HashMap<String, Klevel>
kLevels,
- File distanceOutput, Klevel averagedK)
- throws IOException
- {
- HashMapList<String, Integer> allTuples = new HashMapList<String,
Integer>();
- Integer maxValues = 0;
-
- HashMap<String, Seed> seeds = kLevels.get(kKey).getData();
- Iterator<String> seedKeys = seeds.keySet().iterator();
- File kLevel = new File(distanceOutput.toString() + sep + kKey);
- kLevel.mkdir();
-
- boolean first = true;
- while(seedKeys.hasNext())
- {
- String seedKey = seedKeys.next();
- ArrayList<String> tuples = seeds.get(seedKey).getTuples();
- Iterator<String> tupleIterator = tuples.iterator();
- while(tupleIterator.hasNext())
- {
- String tupleLine = tupleIterator.next();
- String [] bits = tupleLine.split(" ");
- if(first)
- {
- maxValues = Integer.parseInt(bits[1]);
- first = false;
- }
- allTuples.addWithDuplicates("o-" + bits[0],
Integer.parseInt(bits[2]));
- allTuples.addWithDuplicates("a-" + bits[0],
Integer.parseInt(bits[3]));
- }
- }
-
- outputAveragedTuples(allTuples, maxValues, kLevel, averagedK, kKey);
- }
-
- private static void outputAveragedKLevel(HashMap<String, Klevel> ks,
File outputFolder)
- throws IOException
- {
- ArrayList<Double> oPercentage = new ArrayList<Double>();
- for(int index =0; index <6; index ++)
- oPercentage.add(null);
- ArrayList<Double> aPercentage = new ArrayList<Double>();
- for(int index =0; index <6; index ++)
- aPercentage.add(null);
- BufferedWriter outTop = new BufferedWriter(new
FileWriter(outputFolder.toString() + sep + "percentages"));
- Iterator<String> kKeys = ks.keySet().iterator();
- while(kKeys.hasNext())
- {
- String kKey = kKeys.next();
- Klevel k = ks.get(kKey);
- File kLevel = new File(outputFolder.toString() + sep + kKey);
- BufferedWriter out = new BufferedWriter(new
FileWriter(kLevel.toString() + sep + "percentages"));
- Seed kAvergaeTuples = k.getData().get(kKey);
- Iterator<Double> tuples = kAvergaeTuples.getoAverage().iterator();
- tuples.next();
- while(tuples.hasNext())
- {
- Double tuple = tuples.next();
- oPercentage.set(Integer.parseInt(kKey),(tuple /
kAvergaeTuples.getMax()) * 100);
- }
- tuples = kAvergaeTuples.getaAverage().iterator();
- tuples.next();
- while(tuples.hasNext())
- {
- Double tuple = tuples.next();
- aPercentage.set(Integer.parseInt(kKey),(tuple /
kAvergaeTuples.getMax()) * 100);
- }
-
- DecimalFormat format = new DecimalFormat("#.##");
- out.write(kKey + " " +
format.format(oPercentage.get(Integer.parseInt(kKey))) + " " +
- format.format(aPercentage.get(Integer.parseInt(kKey)))
+ "\n");
- out.flush();
- out.close();
- }
-
- Iterator<Double> oiterator = oPercentage.iterator();
- Iterator<Double> aiterator = aPercentage.iterator();
- oiterator.next();
- oiterator.next();
- aiterator.next();
- aiterator.next();
- int index = 2;
- while(oiterator.hasNext())
- {
- Double o = oiterator.next();
- Double a = aiterator.next();
- DecimalFormat format = new DecimalFormat("#.##");
- outTop.write(index + " " + format.format(o) + " " + format.format(a)
+ "\n");
- index++;
- }
- outTop.flush();
- outTop.close();
- }
-
- private static void outputAveragedTuples(HashMapList<String, Integer>
allTuples,
- Integer maxValues, File
kLevelOutput,
- Klevel k, String kKey)
- throws IOException
- {
- Iterator<String> keys = allTuples.keySet().iterator();
- ArrayList<Double> oAveragedTuples = new ArrayList<Double>(50);
- for(int index = 0; index <= 50; index++)
- {
- oAveragedTuples.add(null);
- }
- ArrayList<Double> aAveragedTuples = new ArrayList<Double>(50);
- for(int index = 0; index <= 50; index++)
- {
- aAveragedTuples.add(null);
- }
- ArrayList<Double> oSDTuples = new ArrayList<Double>(50);
- for(int index = 0; index <= 50; index++)
- {
- oSDTuples.add(null);
- }
- ArrayList<Double> aSDTuples = new ArrayList<Double>(50);
- for(int index = 0; index <= 50; index++)
- {
- aSDTuples.add(null);
- }
-
- while(keys.hasNext())
- {
- String key = keys.next();
- String [] bits = key.split("-");
- int index = Integer.parseInt(bits[1]);
- Double average = 0.0;
- Iterator<Integer> tuples = allTuples.get(key).iterator();
- while(tuples.hasNext())
- {
- Integer tuple = tuples.next();
- average += tuple;
- }
- average = average / allTuples.get(key).size();
- double SD = findStandardDeviation(allTuples.get(key));
-
- if(bits[0].equals("o"))
- {
- oAveragedTuples.set(index, average);
- oSDTuples.set(index, SD);
- }
- else
- {
- aAveragedTuples.set(index, average);
- aSDTuples.set(index, SD);
- }
-
- }
- Seed average = new Seed();
- average.setaAverage(aAveragedTuples);
- average.setoAverage(oAveragedTuples);
- average.setMax(maxValues);
- k.getData().put(kKey, average);
-
-
- BufferedWriter out = new BufferedWriter(new
FileWriter(kLevelOutput.toString() + sep + "avergaedTuples"));
- Iterator<Double> adata = aAveragedTuples.iterator();
- Iterator<Double> odata = oAveragedTuples.iterator();
- adata.next();
- odata.next();
- int counter = 1;
- DecimalFormat format = new DecimalFormat("#.##");
- while(adata.hasNext())
- {
- Double a = adata.next();
- Double o = odata.next();
- out.write(counter + " " + maxValues + " " + format.format(o) + " " +
format.format(a) + "\n");
- }
- out.flush();
- out.close();
-
- out = new BufferedWriter(new FileWriter(kLevelOutput.toString() + sep
+ "SDTuples"));
- adata = aSDTuples.iterator();
- odata = oSDTuples.iterator();
- adata.next();
- odata.next();
- counter = 1;
- while(adata.hasNext())
- {
- Double a = adata.next();
- Double o = odata.next();
- out.write(counter + " " + maxValues + " " + format.format(o) + " " +
format.format(a) + "\n");
- }
- double aAverageSD = 0.0;
- double oAverageSD = 0.0;
- Iterator<Double> tuples = aSDTuples.iterator();
- tuples.next();
-
- while(tuples.hasNext())
- {
- Double tuple = tuples.next();
- aAverageSD += tuple;
- }
- aAverageSD = aAverageSD / aSDTuples.size();
- tuples = oSDTuples.iterator();
- tuples.next();
- while(tuples.hasNext())
- {
- Double tuple = tuples.next();
- oAverageSD += tuple;
- }
- oAverageSD = oAverageSD / oSDTuples.size();
-
- out.write(format.format(oAverageSD) + " " + format.format(aAverageSD)
+ "\n");
- out.flush();
- out.close();
- }
-
- private static void readInData(BufferedReader in, ArrayList<String>
tuples)
- throws IOException
- {
- String line = null;
- while((line = in.readLine()) != null)
- {
- tuples.add(line);
- }
- }
-
- private static ArrayList<String> locateCorrectArrayList(HashMap<String,
Query> data, String[] bits)
- {
- Query query = data.get(bits[0]);
- if(query == null)
- {
- query = new Query(new HashMap<String, Distance>());
- data.put(bits[0], query);
- Distance d = new Distance(new HashMap<String, Klevel>());
- String key = null;
- if(bits.length == 4)
- key = "1.0";
- else
- key = bits[3] + "." + bits[4];
- query.getData().put(key, d);
- Klevel k = new Klevel(new HashMap<String, Seed>());
- key = bits[1];
- d.getData().put(key, k);
- Seed s = new Seed();
- key = bits[2];
- k.getData().put(key, s);
- return s.getTuples();
- }
- else
- {
- String key = null;
- if(bits.length == 4)
- key = "1.0";
- else
- key = bits[3] + "." + bits[4];
- Distance d = query.getData().get(key);
- if(d == null)
- {
- d = new Distance(new HashMap<String, Klevel>());
- query.getData().put(key, d);
- key = "";
- Klevel k = new Klevel(new HashMap<String, Seed>());
- key = bits[1];
- d.getData().put(key, k);
- Seed s = new Seed();
- key = bits[2];
- k.getData().put(key, s);
- return s.getTuples();
- }
- else
- {
- key = bits[1];
- Klevel k = d.getData().get(key);
- if(k ==null)
- {
- k = new Klevel(new HashMap<String, Seed>());
- key = bits[1];
- d.getData().put(key, k);
- Seed s = new Seed();
- key = bits[2];
- k.getData().put(key, s);
- return s.getTuples();
- }
- else
- {
- Seed s = new Seed();
- key = bits[2];
- k.getData().put(key, s);
- return s.getTuples();
- }
- }
- }
- }
-
- public static double findStandardDeviation(ArrayList<Integer> array)
- {
- double mean = findMean(array);
- double d1 = 0;
- double d2 = 0;
- double sum = 0;
- for(int i = 0; i < array.size(); i++)
- {
- d2 = (mean - array.get(i))*(mean - array.get(i));
- d1 = d2 + d1;
- }
- return Math.sqrt((d1/(array.size()-1)));
- }
-
- public static double findMean(ArrayList<Integer> array)
- {
- double total = 0;
- for(int i = 0; i < array.size(); i++)
- {
- total = total + array.get(i);
- }
- return total/array.size();
- }
-
-
-
-
-}
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.2.xml
Fri Mar 1 10:09:26 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.2.xml
Wed Mar 6 09:21:27 2013
@@ -18,7 +18,7 @@
<sites>10,5</sites>
</extent>
<extent name="D">
- <sites>1,9</sites>
+ <sites>9</sites>
</extent>
</extents>
</sensor_network>
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.3.xml
Fri Mar 1 10:09:26 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.3.xml
Wed Mar 6 09:21:27 2013
@@ -18,7 +18,7 @@
<sites>10,5</sites>
</extent>
<extent name="D">
- <sites>1,9</sites>
+ <sites>9</sites>
</extent>
</extents>
</sensor_network>
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.4.xml
Fri Mar 1 10:09:26 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.4.xml
Wed Mar 6 09:21:27 2013
@@ -18,7 +18,7 @@
<sites>10,5</sites>
</extent>
<extent name="D">
- <sites>1,9</sites>
+ <sites>9</sites>
</extent>
</extents>
</sensor_network>
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.5.xml
Fri Mar 1 10:09:26 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.5.xml
Wed Mar 6 09:21:27 2013
@@ -18,7 +18,7 @@
<sites>10,5</sites>
</extent>
<extent name="D">
- <sites>1,9</sites>
+ <sites>9</sites>
</extent>
</extents>
</sensor_network>
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.2.properties
Fri Mar 1 10:09:26 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.2.properties
Wed Mar 6 09:21:27 2013
@@ -54,7 +54,7 @@
compiler.allow_discontinuous_sensing = true
# Location of the logical schema
-logical_schema = logicalSchema_query69.2.xml
+logical_schema = logicalSchema_query69.xml
# Location of the physical schema
physical_schema = physicalSchema_query69.2.xml
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.3.properties
Fri Mar 1 10:09:26 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.3.properties
Wed Mar 6 09:21:27 2013
@@ -54,7 +54,7 @@
compiler.allow_discontinuous_sensing = true
# Location of the logical schema
-logical_schema = logicalSchema_query69.3.xml
+logical_schema = logicalSchema_query69.xml
# Location of the physical schema
physical_schema = physicalSchema_query69.3.xml
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.4.properties
Fri Mar 1 10:09:26 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.4.properties
Wed Mar 6 09:21:27 2013
@@ -54,7 +54,7 @@
compiler.allow_discontinuous_sensing = true
# Location of the logical schema
-logical_schema = logicalSchema_query69.4.xml
+logical_schema = logicalSchema_query69.xml
# Location of the physical schema
physical_schema = physicalSchema_query69.4.xml
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.5.properties
Fri Mar 1 10:09:26 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.5.properties
Wed Mar 6 09:21:27 2013
@@ -54,7 +54,7 @@
compiler.allow_discontinuous_sensing = true
# Location of the logical schema
-logical_schema = logicalSchema_query69.5.xml
+logical_schema = logicalSchema_query69.xml
# Location of the physical schema
physical_schema = physicalSchema_query69.5.xml
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/top60.4.xml
Mon Jan 28 04:05:12 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/top60.4.xml
Wed Mar 6 09:21:27 2013
@@ -235,7 +235,7 @@
<radio-link source="29" dest="8" bidirectional="true" energy="254.0"
time="5.9" radio-loss="0"/>
<radio-link source="29" dest="27" bidirectional="true" energy="254.0"
time="5.9" radio-loss="0"/>
<radio-link source="29" dest="28" bidirectional="true" energy="254.0"
time="5.9" radio-loss="0"/>
-<radio-link source="29" dest="5" bidirectional="true" energy="22.0"
time="9.0" radio-loss="0"/>
+<radio-link source="29" dest="5" bidirectional="true" energy="254.0"
time="9.0" radio-loss="0"/>
<radio-link source="29" dest="31" bidirectional="true" energy="132.0"
time="0.9" radio-loss="0"/>
<radio-link source="29" dest="32" bidirectional="true" energy="132.0"
time="0.9" radio-loss="0"/>
<radio-link source="29" dest="33" bidirectional="true" energy="132.0"
time="0.9" radio-loss="0"/>
@@ -248,7 +248,7 @@
<radio-link source="1" dest="8" bidirectional="true" energy="11.0"
time="10.0" radio-loss="0"/>
<radio-link source="1" dest="27" bidirectional="true" energy="66.0"
time="10.0" radio-loss="0"/>
<radio-link source="1" dest="28" bidirectional="true" energy="66.0"
time="10.0" radio-loss="0"/>
-<radio-link source="1" dest="29" bidirectional="true" energy="66.0"
time="10.0" radio-loss="0"/>
+<radio-link source="1" dest="29" bidirectional="true" energy="254.0"
time="10.0" radio-loss="0"/>
<radio-link source="1" dest="30" bidirectional="true" energy="66.0"
time="10.0" radio-loss="0"/>
<radio-link source="1" dest="5" bidirectional="true" energy="252.0"
time="59.0" radio-loss="0"/>
<radio-link source="1" dest="31" bidirectional="true" energy="254.0"
time="5.9" radio-loss="0"/>
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/snee-wsn-manager/src/main/java/uk/ac/manchester/cs/snee/manager/executer/Executer.java
Mon Mar 4 13:20:13 2013
+++
/branches/alan_2012_07_19_unreliableChannels/snee-wsn-manager/src/main/java/uk/ac/manchester/cs/snee/manager/executer/Executer.java
Wed Mar 6 09:21:27 2013
@@ -150,8 +150,8 @@
tuplesReturnedFromEachTypeOfQEP.addWithDuplicates(type.RQEP,
tuplesReturned);
tuplesReturnedFromEachTypeOfQEP.addWithDuplicates(type.MAX,
maxTuplesReturnable);
tuplesReturnedFromEachTypeOfQEP.addWithDuplicates(type.AGGR,
aggreTuples);
- ChannelModelUtils utils = new
ChannelModelUtils(channelModel.getChannelModel(),
rQEP.getLogicalOverlayNetwork());
- utils.plotPacketRates(iteration, executerOutputFolder);
+ // ChannelModelUtils utils = new
ChannelModelUtils(channelModel.getChannelModel(),
rQEP.getLogicalOverlayNetwork());
+ //utils.plotPacketRates(iteration, executerOutputFolder);
channelModel.clearModel();
rQEP.getLogicalOverlayNetwork().removeClonedData();
}
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/snee-wsn-manager/src/main/java/uk/ac/manchester/cs/snee/manager/planner/costbenifitmodel/model/channel/ChannelModelSite.java
Tue Mar 5 10:56:33 2013
+++
/branches/alan_2012_07_19_unreliableChannels/snee-wsn-manager/src/main/java/uk/ac/manchester/cs/snee/manager/planner/costbenifitmodel/model/channel/ChannelModelSite.java
Wed Mar 6 09:21:27 2013
@@ -592,7 +592,7 @@
ChannelModelSite.aggregationTupleTracker.get(op.getSite().getID());
if(currentSitesTracker == null)
currentSitesTracker = new HashMapList<Integer, Boolean>();
- HashMap<String, ArrayList<Boolean>> reducedArrivedpackets =
reduceArrivedPackets(op.getSite());
+ HashMap<String, ArrayList<Boolean>> reducedArrivedpackets =
reduceArrivedPackets(op.getSite(), this.arrivedPackets);
InstanceOperator firstInput = (InstanceOperator) op.getInput(0);
if(op.getSensornetOperator() instanceof SensornetAggrEvalOperator &&
firstInput.getSensornetOperator() instanceof
SensornetAggrMergeOperator)
@@ -696,10 +696,14 @@
Integer key = keys.next();
ArrayList<Boolean> bools = inputSitesTracker.get(key);
Iterator<Boolean> boolIterator = bools.iterator();
+ ArrayList<Boolean> receivedPackets =
reducedArrivedpackets.get(inputSite.getID());
+ Iterator<Boolean> receivedPacketIterator =
receivedPackets.iterator();
while(boolIterator.hasNext())
{
Boolean bool = boolIterator.next();
- currentSitesTracker.addWithDuplicates(key, bool);
+ Boolean recieved = receivedPacketIterator.next();
+ if(recieved)
+ currentSitesTracker.addWithDuplicates(key, bool);
}
}
}
@@ -713,10 +717,14 @@
Integer key = keys.next();
ArrayList<Boolean> bools = inputSitesTracker.get(key);
Iterator<Boolean> boolIterator = bools.iterator();
+ ArrayList<Boolean> receivedPackets =
reducedArrivedpackets.get(inputSite.getID());
+ Iterator<Boolean> receivedPacketIterator =
receivedPackets.iterator();
while(boolIterator.hasNext())
{
Boolean bool = boolIterator.next();
- currentSitesTracker.addWithDuplicates(key, bool);
+ Boolean recieved = receivedPacketIterator.next();
+ if(recieved)
+ currentSitesTracker.addWithDuplicates(key, bool);
}
}
}
@@ -725,26 +733,14 @@
ChannelModelSite.aggregationTupleTracker.put(op.getSite().getID(),
currentSitesTracker);
}
}
-
- if(op.getSensornetOperator() instanceof SensornetAggrEvalOperator)
- {
- int count = 0;
- Iterator<Integer> keys = currentSitesTracker.keySet().iterator();
- while(keys.hasNext())
- {
- Integer key = keys.next();
- Iterator<Boolean> values = currentSitesTracker.get(key).iterator();
- while(values.hasNext())
- {
- if(values.next())
- count++;
- }
- }
- ChannelModelSite.tuplesParticipatingInAggregation = count;
- }
}
- private HashMap<String, ArrayList<Boolean>> reduceArrivedPackets(Site
site)
+ private HashMap<String, ArrayList<Boolean>> getArrivedPackets()
+ {
+ return this.arrivedPackets;
+ }
+
+ private HashMap<String, ArrayList<Boolean>> reduceArrivedPackets(Site
site, HashMap<String, ArrayList<Boolean>> arrivedPackets)
{
HashMap<String, ArrayList<Boolean>> reducedArrivePackets = new
HashMap<String, ArrayList<Boolean>>();
ArrayList<Node> inputs = new ArrayList<Node>(site.getInputsList());
@@ -1366,8 +1362,82 @@
{
checkAggregationTupleTracker(op);
}
+ if(op.getSensornetOperator() instanceof SensornetDeliverOperator)
+ finishTracking(op);
}
}
+
+ private void finishTracking(InstanceOperator op)
+ {
+ HashMapList<Integer, Boolean> currentSitesTracker =
+ ChannelModelSite.aggregationTupleTracker.get(op.getSite().getID());
+ if(currentSitesTracker == null)
+ currentSitesTracker = new HashMapList<Integer, Boolean>();
+ ArrayList<InstanceOperator> operators =
+ overlayNetwork.getQep().getIOT().getOpInstances(op.getSite(),
TraversalOrder.POST_ORDER, true);
+ boolean evalLocatedOnsameSite = false;
+ Iterator<InstanceOperator> operatorIterator = operators.iterator();
+ while(operatorIterator.hasNext())
+ {
+ if(operatorIterator.next().getSensornetOperator() instanceof
SensornetAggrEvalOperator)
+ evalLocatedOnsameSite = true;
+ }
+ int count = 0;
+ if(evalLocatedOnsameSite)
+ {
+ Iterator<Integer> keys = currentSitesTracker.keySet().iterator();
+ while(keys.hasNext())
+ {
+ Integer key = keys.next();
+ Iterator<Boolean> values = currentSitesTracker.get(key).iterator();
+ while(values.hasNext())
+ {
+ if(values.next())
+ count++;
+ }
+ }
+ }
+ else
+ {
+ HashMap<String, ArrayList<Boolean>> reducedArrivedpackets =
reduceArrivedPackets(op.getSite(), this.arrivedPackets);
+ Iterator<Node> inputSites = op.getSite().getInputsList().iterator();
+ while(inputSites.hasNext())
+ {
+ Site inputSite = (Site) inputSites.next();
+ HashMapList<Integer, Boolean> inputSitesTracker =
+ ChannelModelSite.aggregationTupleTracker.get(inputSite.getID());
+ Iterator<Integer> keys = inputSitesTracker.keySet().iterator();
+ while(keys.hasNext())
+ {
+ Integer key = keys.next();
+ ArrayList<Boolean> bools = inputSitesTracker.get(key);
+ Iterator<Boolean> boolIterator = bools.iterator();
+ ArrayList<Boolean> receivedPackets =
reducedArrivedpackets.get(inputSite.getID());
+ Iterator<Boolean> receivedPacketIterator =
receivedPackets.iterator();
+ while(boolIterator.hasNext())
+ {
+ Boolean bool = boolIterator.next();
+ Boolean recieved = receivedPacketIterator.next();
+ if(recieved)
+ currentSitesTracker.addWithDuplicates(key, bool);
+ }
+ }
+ }
+ Iterator<Integer> keys = currentSitesTracker.keySet().iterator();
+ while(keys.hasNext())
+ {
+ Integer key = keys.next();
+ Iterator<Boolean> values = currentSitesTracker.get(key).iterator();
+ while(values.hasNext())
+ {
+ if(values.next())
+ count++;
+ }
+ }
+ }
+
+ ChannelModelSite.tuplesParticipatingInAggregation = count;
+ }
public static void resetAggreData()
{
Author: alan.bar...@gmail.com
Date: Wed Mar 6 09:21:27 2013
Log: fixed codnor inputs, fixed aggregation tuple calculator
http://code.google.com/p/snee/source/detail?r=1369
Added:
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/submit.txt
Modified:
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/java/uk/ac/manchester/snee/client/RelibaleChannelClient.java
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/java/uk/ac/manchester/snee/client/utils/CondorScriptGenerator.java
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/java/uk/ac/manchester/snee/client/utils/collateResults.java
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.2.xml
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.3.xml
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.4.xml
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.5.xml
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.2.properties
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.3.properties
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.4.properties
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.5.properties
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/top60.4.xml
/branches/alan_2012_07_19_unreliableChannels/snee-wsn-manager/src/main/java/uk/ac/manchester/cs/snee/manager/executer/Executer.java
/branches/alan_2012_07_19_unreliableChannels/snee-wsn-manager/src/main/java/uk/ac/manchester/cs/snee/manager/planner/costbenifitmodel/model/channel/ChannelModelSite.java
=======================================
--- /dev/null
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/submit.txt
Wed Mar 6 09:21:27 2013
@@ -0,0 +1,10415 @@
+universe = vanilla
+executable = start.sh
+when_to_transfer_output = ON_EXIT
+Should_Transfer_Files = YES
+transfer_input_files = ../SNEE.jar,../jre.tar.gz
+Requirements = (OpSys == "LINUX")
+Request_Disk = 3000000
+request_memory = 2048
+#Output = output$(Process).txt
+#Error = error$(Process).txt
+log = log.txt
+Output = out.txt
+Error = err.txt
+notification = error
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.2.properties 1 0 1
+initialdir = query1.2.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.2.properties 1 0 0.8
+initialdir = query1.2.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.2.properties 1 0 0.6
+initialdir = query1.2.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.2.properties 1 0 0.4
+initialdir = query1.2.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.2.properties 1 0 0.2
+initialdir = query1.2.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.3.properties 1 0 1
+initialdir = query1.3.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.3.properties 1 0 0.8
+initialdir = query1.3.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.3.properties 1 0 0.6
+initialdir = query1.3.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.3.properties 1 0 0.4
+initialdir = query1.3.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.3.properties 1 0 0.2
+initialdir = query1.3.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.4.properties 1 0 1
+initialdir = query1.4.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.4.properties 1 0 0.8
+initialdir = query1.4.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.4.properties 1 0 0.6
+initialdir = query1.4.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.4.properties 1 0 0.4
+initialdir = query1.4.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.4.properties 1 0 0.2
+initialdir = query1.4.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.5.properties 1 0 1
+initialdir = query1.5.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.5.properties 1 0 0.8
+initialdir = query1.5.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.5.properties 1 0 0.6
+initialdir = query1.5.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.5.properties 1 0 0.4
+initialdir = query1.5.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee1.5.properties 1 0 0.2
+initialdir = query1.5.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.2.properties 2 0 1
+initialdir = query2.2.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.2.properties 2 0 0.8
+initialdir = query2.2.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.2.properties 2 0 0.6
+initialdir = query2.2.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.2.properties 2 0 0.4
+initialdir = query2.2.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.2.properties 2 0 0.2
+initialdir = query2.2.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.3.properties 2 0 1
+initialdir = query2.3.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.3.properties 2 0 0.8
+initialdir = query2.3.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.3.properties 2 0 0.6
+initialdir = query2.3.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.3.properties 2 0 0.4
+initialdir = query2.3.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.3.properties 2 0 0.2
+initialdir = query2.3.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.4.properties 2 0 1
+initialdir = query2.4.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.4.properties 2 0 0.8
+initialdir = query2.4.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.4.properties 2 0 0.6
+initialdir = query2.4.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.4.properties 2 0 0.4
+initialdir = query2.4.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.4.properties 2 0 0.2
+initialdir = query2.4.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.5.properties 2 0 1
+initialdir = query2.5.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.5.properties 2 0 0.8
+initialdir = query2.5.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.5.properties 2 0 0.6
+initialdir = query2.5.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.5.properties 2 0 0.4
+initialdir = query2.5.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee2.5.properties 2 0 0.2
+initialdir = query2.5.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.2.properties 3 0 1
+initialdir = query3.2.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.2.properties 3 0 0.8
+initialdir = query3.2.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.2.properties 3 0 0.6
+initialdir = query3.2.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.2.properties 3 0 0.4
+initialdir = query3.2.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.2.properties 3 0 0.2
+initialdir = query3.2.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.3.properties 3 0 1
+initialdir = query3.3.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.3.properties 3 0 0.8
+initialdir = query3.3.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.3.properties 3 0 0.6
+initialdir = query3.3.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.3.properties 3 0 0.4
+initialdir = query3.3.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.3.properties 3 0 0.2
+initialdir = query3.3.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.4.properties 3 0 1
+initialdir = query3.4.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.4.properties 3 0 0.8
+initialdir = query3.4.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.4.properties 3 0 0.6
+initialdir = query3.4.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.4.properties 3 0 0.4
+initialdir = query3.4.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.4.properties 3 0 0.2
+initialdir = query3.4.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.5.properties 3 0 1
+initialdir = query3.5.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.5.properties 3 0 0.8
+initialdir = query3.5.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.5.properties 3 0 0.6
+initialdir = query3.5.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.5.properties 3 0 0.4
+initialdir = query3.5.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee3.5.properties 3 0 0.2
+initialdir = query3.5.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.2.properties 4 0 1
+initialdir = query4.2.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.2.properties 4 0 0.8
+initialdir = query4.2.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.2.properties 4 0 0.6
+initialdir = query4.2.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.2.properties 4 0 0.4
+initialdir = query4.2.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.2.properties 4 0 0.2
+initialdir = query4.2.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.3.properties 4 0 1
+initialdir = query4.3.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.3.properties 4 0 0.8
+initialdir = query4.3.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.3.properties 4 0 0.6
+initialdir = query4.3.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.3.properties 4 0 0.4
+initialdir = query4.3.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.3.properties 4 0 0.2
+initialdir = query4.3.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.4.properties 4 0 1
+initialdir = query4.4.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.4.properties 4 0 0.8
+initialdir = query4.4.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.4.properties 4 0 0.6
+initialdir = query4.4.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.4.properties 4 0 0.4
+initialdir = query4.4.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.4.properties 4 0 0.2
+initialdir = query4.4.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.5.properties 4 0 1
+initialdir = query4.5.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.5.properties 4 0 0.8
+initialdir = query4.5.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.5.properties 4 0 0.6
+initialdir = query4.5.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.5.properties 4 0 0.4
+initialdir = query4.5.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee4.5.properties 4 0 0.2
+initialdir = query4.5.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.2.properties 5 0 1
+initialdir = query5.2.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.2.properties 5 0 0.8
+initialdir = query5.2.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.2.properties 5 0 0.6
+initialdir = query5.2.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.2.properties 5 0 0.4
+initialdir = query5.2.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.2.properties 5 0 0.2
+initialdir = query5.2.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.3.properties 5 0 1
+initialdir = query5.3.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.3.properties 5 0 0.8
+initialdir = query5.3.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.3.properties 5 0 0.6
+initialdir = query5.3.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.3.properties 5 0 0.4
+initialdir = query5.3.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.3.properties 5 0 0.2
+initialdir = query5.3.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.4.properties 5 0 1
+initialdir = query5.4.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.4.properties 5 0 0.8
+initialdir = query5.4.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.4.properties 5 0 0.6
+initialdir = query5.4.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.4.properties 5 0 0.4
+initialdir = query5.4.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.4.properties 5 0 0.2
+initialdir = query5.4.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.5.properties 5 0 1
+initialdir = query5.5.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.5.properties 5 0 0.8
+initialdir = query5.5.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.5.properties 5 0 0.6
+initialdir = query5.5.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.5.properties 5 0 0.4
+initialdir = query5.5.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee5.5.properties 5 0 0.2
+initialdir = query5.5.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.2.properties 6 0 1
+initialdir = query6.2.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.2.properties 6 0 0.8
+initialdir = query6.2.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.2.properties 6 0 0.6
+initialdir = query6.2.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.2.properties 6 0 0.4
+initialdir = query6.2.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.2.properties 6 0 0.2
+initialdir = query6.2.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.3.properties 6 0 1
+initialdir = query6.3.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.3.properties 6 0 0.8
+initialdir = query6.3.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.3.properties 6 0 0.6
+initialdir = query6.3.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.3.properties 6 0 0.4
+initialdir = query6.3.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.3.properties 6 0 0.2
+initialdir = query6.3.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.4.properties 6 0 1
+initialdir = query6.4.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.4.properties 6 0 0.8
+initialdir = query6.4.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.4.properties 6 0 0.6
+initialdir = query6.4.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.4.properties 6 0 0.4
+initialdir = query6.4.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.4.properties 6 0 0.2
+initialdir = query6.4.0.0.2
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.5.properties 6 0 1
+initialdir = query6.5.0.1
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.5.properties 6 0 0.8
+initialdir = query6.5.0.0.8
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.5.properties 6 0 0.6
+initialdir = query6.5.0.0.6
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.5.properties 6 0 0.4
+initialdir = query6.5.0.0.4
+queue
+
+Arguments = SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow_;
snee6.5.properties 6 0 0.2
+initialdir = query6.5.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.2.properties 60 0 1
+initialdir = query60.2.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.2.properties 60 0 0.8
+initialdir = query60.2.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.2.properties 60 0 0.6
+initialdir = query60.2.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.2.properties 60 0 0.4
+initialdir = query60.2.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.2.properties 60 0 0.2
+initialdir = query60.2.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.3.properties 60 0 1
+initialdir = query60.3.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.3.properties 60 0 0.8
+initialdir = query60.3.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.3.properties 60 0 0.6
+initialdir = query60.3.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.3.properties 60 0 0.4
+initialdir = query60.3.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.3.properties 60 0 0.2
+initialdir = query60.3.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.4.properties 60 0 1
+initialdir = query60.4.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.4.properties 60 0 0.8
+initialdir = query60.4.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.4.properties 60 0 0.6
+initialdir = query60.4.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.4.properties 60 0 0.4
+initialdir = query60.4.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.4.properties 60 0 0.2
+initialdir = query60.4.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.5.properties 60 0 1
+initialdir = query60.5.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.5.properties 60 0 0.8
+initialdir = query60.5.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.5.properties 60 0 0.6
+initialdir = query60.5.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.5.properties 60 0 0.4
+initialdir = query60.5.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee60.5.properties 60 0 0.2
+initialdir = query60.5.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.2.properties 62 0 1
+initialdir = query62.2.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.2.properties 62 0 0.8
+initialdir = query62.2.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.2.properties 62 0 0.6
+initialdir = query62.2.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.2.properties 62 0 0.4
+initialdir = query62.2.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.2.properties 62 0 0.2
+initialdir = query62.2.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.3.properties 62 0 1
+initialdir = query62.3.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.3.properties 62 0 0.8
+initialdir = query62.3.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.3.properties 62 0 0.6
+initialdir = query62.3.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.3.properties 62 0 0.4
+initialdir = query62.3.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.3.properties 62 0 0.2
+initialdir = query62.3.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.4.properties 62 0 1
+initialdir = query62.4.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.4.properties 62 0 0.8
+initialdir = query62.4.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.4.properties 62 0 0.6
+initialdir = query62.4.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.4.properties 62 0 0.4
+initialdir = query62.4.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.4.properties 62 0 0.2
+initialdir = query62.4.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.5.properties 62 0 1
+initialdir = query62.5.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.5.properties 62 0 0.8
+initialdir = query62.5.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.5.properties 62 0 0.6
+initialdir = query62.5.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.5.properties 62 0 0.4
+initialdir = query62.5.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee62.5.properties 62 0 0.2
+initialdir = query62.5.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.2.properties 64 0 1
+initialdir = query64.2.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.2.properties 64 0 0.8
+initialdir = query64.2.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.2.properties 64 0 0.6
+initialdir = query64.2.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.2.properties 64 0 0.4
+initialdir = query64.2.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.2.properties 64 0 0.2
+initialdir = query64.2.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.3.properties 64 0 1
+initialdir = query64.3.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.3.properties 64 0 0.8
+initialdir = query64.3.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.3.properties 64 0 0.6
+initialdir = query64.3.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.3.properties 64 0 0.4
+initialdir = query64.3.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.3.properties 64 0 0.2
+initialdir = query64.3.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.4.properties 64 0 1
+initialdir = query64.4.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.4.properties 64 0 0.8
+initialdir = query64.4.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.4.properties 64 0 0.6
+initialdir = query64.4.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.4.properties 64 0 0.4
+initialdir = query64.4.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.4.properties 64 0 0.2
+initialdir = query64.4.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.5.properties 64 0 1
+initialdir = query64.5.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.5.properties 64 0 0.8
+initialdir = query64.5.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.5.properties 64 0 0.6
+initialdir = query64.5.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.5.properties 64 0 0.4
+initialdir = query64.5.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee64.5.properties 64 0 0.2
+initialdir = query64.5.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.2.properties 67 0 1
+initialdir = query67.2.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.2.properties 67 0 0.8
+initialdir = query67.2.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.2.properties 67 0 0.6
+initialdir = query67.2.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.2.properties 67 0 0.4
+initialdir = query67.2.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.2.properties 67 0 0.2
+initialdir = query67.2.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.3.properties 67 0 1
+initialdir = query67.3.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.3.properties 67 0 0.8
+initialdir = query67.3.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.3.properties 67 0 0.6
+initialdir = query67.3.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.3.properties 67 0 0.4
+initialdir = query67.3.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.3.properties 67 0 0.2
+initialdir = query67.3.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.4.properties 67 0 1
+initialdir = query67.4.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.4.properties 67 0 0.8
+initialdir = query67.4.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.4.properties 67 0 0.6
+initialdir = query67.4.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.4.properties 67 0 0.4
+initialdir = query67.4.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.4.properties 67 0 0.2
+initialdir = query67.4.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.5.properties 67 0 1
+initialdir = query67.5.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.5.properties 67 0 0.8
+initialdir = query67.5.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.5.properties 67 0 0.6
+initialdir = query67.5.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.5.properties 67 0 0.4
+initialdir = query67.5.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee67.5.properties 67 0 0.2
+initialdir = query67.5.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.2.properties 68 0 1
+initialdir = query68.2.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.2.properties 68 0 0.8
+initialdir = query68.2.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.2.properties 68 0 0.6
+initialdir = query68.2.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.2.properties 68 0 0.4
+initialdir = query68.2.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.2.properties 68 0 0.2
+initialdir = query68.2.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.3.properties 68 0 1
+initialdir = query68.3.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.3.properties 68 0 0.8
+initialdir = query68.3.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.3.properties 68 0 0.6
+initialdir = query68.3.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.3.properties 68 0 0.4
+initialdir = query68.3.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.3.properties 68 0 0.2
+initialdir = query68.3.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.4.properties 68 0 1
+initialdir = query68.4.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.4.properties 68 0 0.8
+initialdir = query68.4.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.4.properties 68 0 0.6
+initialdir = query68.4.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.4.properties 68 0 0.4
+initialdir = query68.4.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.4.properties 68 0 0.2
+initialdir = query68.4.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.5.properties 68 0 1
+initialdir = query68.5.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.5.properties 68 0 0.8
+initialdir = query68.5.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.5.properties 68 0 0.6
+initialdir = query68.5.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.5.properties 68 0 0.4
+initialdir = query68.5.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee68.5.properties 68 0 0.2
+initialdir = query68.5.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.2.properties 69 0 1
+initialdir = query69.2.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.2.properties 69 0 0.8
+initialdir = query69.2.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.2.properties 69 0 0.6
+initialdir = query69.2.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.2.properties 69 0 0.4
+initialdir = query69.2.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.2.properties 69 0 0.2
+initialdir = query69.2.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.3.properties 69 0 1
+initialdir = query69.3.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.3.properties 69 0 0.8
+initialdir = query69.3.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.3.properties 69 0 0.6
+initialdir = query69.3.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.3.properties 69 0 0.4
+initialdir = query69.3.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.3.properties 69 0 0.2
+initialdir = query69.3.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.4.properties 69 0 1
+initialdir = query69.4.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.4.properties 69 0 0.8
+initialdir = query69.4.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.4.properties 69 0 0.6
+initialdir = query69.4.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.4.properties 69 0 0.4
+initialdir = query69.4.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.4.properties 69 0 0.2
+initialdir = query69.4.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.5.properties 69 0 1
+initialdir = query69.5.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.5.properties 69 0 0.8
+initialdir = query69.5.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.5.properties 69 0 0.6
+initialdir = query69.5.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.5.properties 69 0 0.4
+initialdir = query69.5.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_sq1.sq1x_as_qx_FROM_(SELECT_anow.x_as_sq1x_FROM_A[NOW]_anow,_B[NOW]_bnow_WHERE_anow.x=bnow.x)_sq1,_(SELECT_cnow.x_as_sq2x_FROM_C[NOW]_cnow,_D[NOW]_dnow_WHERE_cnow.x=dnow.x)_sq2_WHERE_sq1.sq1x=sq2.sq2x;
snee69.5.properties 69 0 0.2
+initialdir = query69.5.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee70.2.properties 70 0 1
+initialdir = query70.2.0.1
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee70.2.properties 70 0 0.8
+initialdir = query70.2.0.0.8
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee70.2.properties 70 0 0.6
+initialdir = query70.2.0.0.6
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee70.2.properties 70 0 0.4
+initialdir = query70.2.0.0.4
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee70.2.properties 70 0 0.2
+initialdir = query70.2.0.0.2
+queue
+
+Arguments =
SELECT_RSTREAM_anow.x_as_qx_FROM_A[NOW]_anow,_(SELECT_bnow.x_as_sq1x_FROM_B[NOW]_bnow,_C[NOW]_cnow_WHERE_bnow.x=cnow.x)_sq1_WHERE_anow.x=sq1.sq1x;
snee70.3.properties 70 0 1
+initialdir = query70.3.0.1
+queue
***The diff for this file has been truncated for email.***
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/java/uk/ac/manchester/snee/client/RelibaleChannelClient.java
Mon Mar 4 09:34:19 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/java/uk/ac/manchester/snee/client/RelibaleChannelClient.java
Wed Mar 6 09:21:27 2013
@@ -40,7 +40,7 @@
{
private static String sep = System.getProperty("file.separator");
- private static int queryid =1;
+ private static int queryid =30;
protected static int testNo = 1;
protected static int kResil = 2;
private static int max = 90;
@@ -216,8 +216,8 @@
// {
//get query & schemas
// String currentQuery = queryIterator.next();
- // String currentQuery = "SELECT RSTREAM AVG(anow.x) as qx FROM A[NOW]
anow ;";
- String currentQuery = "SELECT RSTREAM anow.x as qx FROM A[NOW] anow ;";
+ String currentQuery = "SELECT RSTREAM AVG(anow.x) as qx FROM A[NOW]
anow ;";
+ // String currentQuery = "SELECT RSTREAM anow.x as qx FROM A[NOW]
anow ;";
// String currentQuery = "SELECT RSTREAM anow.x as qx FROM A[NOW]
anow,(SELECT bnow.x as sq1x FROM B[NOW] bnow, C[NOW] cnow WHERE
bnow.x=cnow.x) sq1 WHERE anow.x=sq1.sq1x;";
// String currentQuery = "SELECT RSTREAM sq1.sq1x as qx FROM (SELECT
anow.x as sq1x FROM A[NOW] anow, B[NOW] bnow WHERE anow.x=bnow.x) sq1,
(SELECT cnow.x as sq2x FROM C[NOW] cnow, D[NOW] dnow WHERE cnow.x=dnow.x)
sq2 WHERE sq1.sq1x=sq2.sq2x;";
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/java/uk/ac/manchester/snee/client/utils/CondorScriptGenerator.java
Fri Mar 1 10:09:26 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/java/uk/ac/manchester/snee/client/utils/CondorScriptGenerator.java
Wed Mar 6 09:21:27 2013
@@ -25,7 +25,7 @@
public static void main(String[] args)
{
-
+ //possible ids are 1,2,3,4,5,6,30,31,32,33,34,36,60,62,64,67,68
seeds.add(new Long(0));
seeds.add(new Long(1));
seeds.add(new Long(10));
@@ -36,7 +36,7 @@
seeds.add(new Long(35));
seeds.add(new Long(40));
seeds.add(new Long(45));
- validIds.addAll(Arrays.asList(30,31,32,33,34,36));
+
validIds.addAll(Arrays.asList(1,2,3,4,5,6,30,31,32,33,34,36,60,62,64,67,68));
File condorFile = new File("condor");
if(!condorFile.exists())
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/java/uk/ac/manchester/snee/client/utils/collateResults.java
Fri Mar 1 10:09:26 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/java/uk/ac/manchester/snee/client/utils/collateResults.java
Wed Mar 6 09:21:27 2013
@@ -1,443 +0,0 @@
-package uk.ac.manchester.snee.client.utils;
-
-import java.io.BufferedReader;
-import java.io.BufferedWriter;
-import java.io.File;
-import java.io.FileReader;
-import java.io.FileWriter;
-import java.io.IOException;
-import java.text.DecimalFormat;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.Iterator;
-
-import uk.ac.manchester.cs.snee.compiler.costmodels.HashMapList;
-
-public class collateResults
-{
-
- private static String sep = System.getProperty("file.separator");
-
- public static void main(String [] args)
- {
- try
- {
- File root = new File("/local/BigSubmit");
- HashMap<String, Query> data = new HashMap<String, Query>();
- File[] listedFiles = root.listFiles();
- int max = listedFiles.length;
- for(int counter = 0; counter < max; counter++)
- {
- File folder = listedFiles[counter];
- if(folder.isDirectory())
- {
- String[] firstBits = folder.toString().split("/");
- String fileName = firstBits[firstBits.length -1];
-
- // Process extractor = Runtime.getRuntime().exec(new String("tar
-xf /local/BigSubmit/" + fileName + "/output.tgz"));
- // extractor.waitFor();
-
- String[] bits = fileName.split("\\.");
- File outputTuplesFile = null;
- if(bits.length == 4)
- {
- outputTuplesFile = new File(folder.toString() + sep
+ "output/" + bits[0] + sep+
- "AutonomicManData" + sep
+ "executer" + sep +
- "1.0" + sep + "tupleOutput");
- }
- else
- {
- outputTuplesFile = new File(folder.toString() + sep
+ "output/" + bits[0] + sep +
- "AutonomicManData" + sep
+ "executer" + sep + bits[3] +
- "." + bits[4] + sep
+ "tupleOutput");
- }
- if(outputTuplesFile.exists())
- {
- BufferedReader in = new BufferedReader(new
FileReader(outputTuplesFile));
- ArrayList<String> tuples = locateCorrectArrayList(data, bits);
- System.out.println("reading in file for "+ bits[0]);
- readInData(in, tuples);
- in.close();
- }
- }
- }
-
- System.out.println("starting output");
- outputData(data);
- }
- catch(Exception e)
- {
- System.out.println(e.getMessage());
- e.printStackTrace();
- }
- }
-
- private static void outputData( HashMap<String, Query> data)
- throws IOException
- {
- HashMap<String, Query> averagedData = new HashMap<String, Query>();
- File distanceOutput = null;
- File output = new File("/local/BigSubmit/output");
- output.mkdir();
- Iterator<String> queryKeys = data.keySet().iterator();
- while(queryKeys.hasNext())
- {
- String queryKey = queryKeys.next();
- Query query = new Query(new HashMap<String, Distance>());
- averagedData.put(queryKey, query);
- File queryOutput = new File(output.toString() + sep + queryKey);
- queryOutput.mkdir();
- HashMap<String, Distance> distances = data.get(queryKey).getData();
- Iterator<String> distanceKeys = distances.keySet().iterator();
- while(distanceKeys.hasNext())
- {
- String distanceKey = distanceKeys.next();
- Distance d = new Distance(new HashMap<String, Klevel>());
- query.getData().put(distanceKey, d);
- distanceOutput = new File(queryOutput.toString() + sep +
distanceKey);
- distanceOutput.mkdir();
- HashMap<String, Klevel> kLevels =
distances.get(distanceKey).getData();
- Iterator<String> klevelKeys = kLevels.keySet().iterator();
- while(klevelKeys.hasNext())
- {
- String kKey = klevelKeys.next();
- Klevel k = new Klevel(new HashMap<String, Seed>());
- d.getData().put(kKey, k);
- absorbSeeds(kKey, kLevels, distanceOutput, k);
- }
- }
- }
- data = null;
- queryKeys = averagedData.keySet().iterator();
- while(queryKeys.hasNext())
- {
- String queryKey = queryKeys.next();
- File queryOutput = new File(output.toString() + sep + queryKey);
- HashMap<String, Distance> distances =
averagedData.get(queryKey).getData();
- Iterator<String> distanceKeys = distances.keySet().iterator();
- while(distanceKeys.hasNext())
- {
- String distanceKey = distanceKeys.next();
- distanceOutput = new File(queryOutput.toString() + sep +
distanceKey);
- HashMap<String, Klevel> kLevels =
distances.get(distanceKey).getData();
- outputAveragedKLevel(kLevels, distanceOutput);
- }
- }
-
-
- }
-
- private static void absorbSeeds(String kKey, HashMap<String, Klevel>
kLevels,
- File distanceOutput, Klevel averagedK)
- throws IOException
- {
- HashMapList<String, Integer> allTuples = new HashMapList<String,
Integer>();
- Integer maxValues = 0;
-
- HashMap<String, Seed> seeds = kLevels.get(kKey).getData();
- Iterator<String> seedKeys = seeds.keySet().iterator();
- File kLevel = new File(distanceOutput.toString() + sep + kKey);
- kLevel.mkdir();
-
- boolean first = true;
- while(seedKeys.hasNext())
- {
- String seedKey = seedKeys.next();
- ArrayList<String> tuples = seeds.get(seedKey).getTuples();
- Iterator<String> tupleIterator = tuples.iterator();
- while(tupleIterator.hasNext())
- {
- String tupleLine = tupleIterator.next();
- String [] bits = tupleLine.split(" ");
- if(first)
- {
- maxValues = Integer.parseInt(bits[1]);
- first = false;
- }
- allTuples.addWithDuplicates("o-" + bits[0],
Integer.parseInt(bits[2]));
- allTuples.addWithDuplicates("a-" + bits[0],
Integer.parseInt(bits[3]));
- }
- }
-
- outputAveragedTuples(allTuples, maxValues, kLevel, averagedK, kKey);
- }
-
- private static void outputAveragedKLevel(HashMap<String, Klevel> ks,
File outputFolder)
- throws IOException
- {
- ArrayList<Double> oPercentage = new ArrayList<Double>();
- for(int index =0; index <6; index ++)
- oPercentage.add(null);
- ArrayList<Double> aPercentage = new ArrayList<Double>();
- for(int index =0; index <6; index ++)
- aPercentage.add(null);
- BufferedWriter outTop = new BufferedWriter(new
FileWriter(outputFolder.toString() + sep + "percentages"));
- Iterator<String> kKeys = ks.keySet().iterator();
- while(kKeys.hasNext())
- {
- String kKey = kKeys.next();
- Klevel k = ks.get(kKey);
- File kLevel = new File(outputFolder.toString() + sep + kKey);
- BufferedWriter out = new BufferedWriter(new
FileWriter(kLevel.toString() + sep + "percentages"));
- Seed kAvergaeTuples = k.getData().get(kKey);
- Iterator<Double> tuples = kAvergaeTuples.getoAverage().iterator();
- tuples.next();
- while(tuples.hasNext())
- {
- Double tuple = tuples.next();
- oPercentage.set(Integer.parseInt(kKey),(tuple /
kAvergaeTuples.getMax()) * 100);
- }
- tuples = kAvergaeTuples.getaAverage().iterator();
- tuples.next();
- while(tuples.hasNext())
- {
- Double tuple = tuples.next();
- aPercentage.set(Integer.parseInt(kKey),(tuple /
kAvergaeTuples.getMax()) * 100);
- }
-
- DecimalFormat format = new DecimalFormat("#.##");
- out.write(kKey + " " +
format.format(oPercentage.get(Integer.parseInt(kKey))) + " " +
- format.format(aPercentage.get(Integer.parseInt(kKey)))
+ "\n");
- out.flush();
- out.close();
- }
-
- Iterator<Double> oiterator = oPercentage.iterator();
- Iterator<Double> aiterator = aPercentage.iterator();
- oiterator.next();
- oiterator.next();
- aiterator.next();
- aiterator.next();
- int index = 2;
- while(oiterator.hasNext())
- {
- Double o = oiterator.next();
- Double a = aiterator.next();
- DecimalFormat format = new DecimalFormat("#.##");
- outTop.write(index + " " + format.format(o) + " " + format.format(a)
+ "\n");
- index++;
- }
- outTop.flush();
- outTop.close();
- }
-
- private static void outputAveragedTuples(HashMapList<String, Integer>
allTuples,
- Integer maxValues, File
kLevelOutput,
- Klevel k, String kKey)
- throws IOException
- {
- Iterator<String> keys = allTuples.keySet().iterator();
- ArrayList<Double> oAveragedTuples = new ArrayList<Double>(50);
- for(int index = 0; index <= 50; index++)
- {
- oAveragedTuples.add(null);
- }
- ArrayList<Double> aAveragedTuples = new ArrayList<Double>(50);
- for(int index = 0; index <= 50; index++)
- {
- aAveragedTuples.add(null);
- }
- ArrayList<Double> oSDTuples = new ArrayList<Double>(50);
- for(int index = 0; index <= 50; index++)
- {
- oSDTuples.add(null);
- }
- ArrayList<Double> aSDTuples = new ArrayList<Double>(50);
- for(int index = 0; index <= 50; index++)
- {
- aSDTuples.add(null);
- }
-
- while(keys.hasNext())
- {
- String key = keys.next();
- String [] bits = key.split("-");
- int index = Integer.parseInt(bits[1]);
- Double average = 0.0;
- Iterator<Integer> tuples = allTuples.get(key).iterator();
- while(tuples.hasNext())
- {
- Integer tuple = tuples.next();
- average += tuple;
- }
- average = average / allTuples.get(key).size();
- double SD = findStandardDeviation(allTuples.get(key));
-
- if(bits[0].equals("o"))
- {
- oAveragedTuples.set(index, average);
- oSDTuples.set(index, SD);
- }
- else
- {
- aAveragedTuples.set(index, average);
- aSDTuples.set(index, SD);
- }
-
- }
- Seed average = new Seed();
- average.setaAverage(aAveragedTuples);
- average.setoAverage(oAveragedTuples);
- average.setMax(maxValues);
- k.getData().put(kKey, average);
-
-
- BufferedWriter out = new BufferedWriter(new
FileWriter(kLevelOutput.toString() + sep + "avergaedTuples"));
- Iterator<Double> adata = aAveragedTuples.iterator();
- Iterator<Double> odata = oAveragedTuples.iterator();
- adata.next();
- odata.next();
- int counter = 1;
- DecimalFormat format = new DecimalFormat("#.##");
- while(adata.hasNext())
- {
- Double a = adata.next();
- Double o = odata.next();
- out.write(counter + " " + maxValues + " " + format.format(o) + " " +
format.format(a) + "\n");
- }
- out.flush();
- out.close();
-
- out = new BufferedWriter(new FileWriter(kLevelOutput.toString() + sep
+ "SDTuples"));
- adata = aSDTuples.iterator();
- odata = oSDTuples.iterator();
- adata.next();
- odata.next();
- counter = 1;
- while(adata.hasNext())
- {
- Double a = adata.next();
- Double o = odata.next();
- out.write(counter + " " + maxValues + " " + format.format(o) + " " +
format.format(a) + "\n");
- }
- double aAverageSD = 0.0;
- double oAverageSD = 0.0;
- Iterator<Double> tuples = aSDTuples.iterator();
- tuples.next();
-
- while(tuples.hasNext())
- {
- Double tuple = tuples.next();
- aAverageSD += tuple;
- }
- aAverageSD = aAverageSD / aSDTuples.size();
- tuples = oSDTuples.iterator();
- tuples.next();
- while(tuples.hasNext())
- {
- Double tuple = tuples.next();
- oAverageSD += tuple;
- }
- oAverageSD = oAverageSD / oSDTuples.size();
-
- out.write(format.format(oAverageSD) + " " + format.format(aAverageSD)
+ "\n");
- out.flush();
- out.close();
- }
-
- private static void readInData(BufferedReader in, ArrayList<String>
tuples)
- throws IOException
- {
- String line = null;
- while((line = in.readLine()) != null)
- {
- tuples.add(line);
- }
- }
-
- private static ArrayList<String> locateCorrectArrayList(HashMap<String,
Query> data, String[] bits)
- {
- Query query = data.get(bits[0]);
- if(query == null)
- {
- query = new Query(new HashMap<String, Distance>());
- data.put(bits[0], query);
- Distance d = new Distance(new HashMap<String, Klevel>());
- String key = null;
- if(bits.length == 4)
- key = "1.0";
- else
- key = bits[3] + "." + bits[4];
- query.getData().put(key, d);
- Klevel k = new Klevel(new HashMap<String, Seed>());
- key = bits[1];
- d.getData().put(key, k);
- Seed s = new Seed();
- key = bits[2];
- k.getData().put(key, s);
- return s.getTuples();
- }
- else
- {
- String key = null;
- if(bits.length == 4)
- key = "1.0";
- else
- key = bits[3] + "." + bits[4];
- Distance d = query.getData().get(key);
- if(d == null)
- {
- d = new Distance(new HashMap<String, Klevel>());
- query.getData().put(key, d);
- key = "";
- Klevel k = new Klevel(new HashMap<String, Seed>());
- key = bits[1];
- d.getData().put(key, k);
- Seed s = new Seed();
- key = bits[2];
- k.getData().put(key, s);
- return s.getTuples();
- }
- else
- {
- key = bits[1];
- Klevel k = d.getData().get(key);
- if(k ==null)
- {
- k = new Klevel(new HashMap<String, Seed>());
- key = bits[1];
- d.getData().put(key, k);
- Seed s = new Seed();
- key = bits[2];
- k.getData().put(key, s);
- return s.getTuples();
- }
- else
- {
- Seed s = new Seed();
- key = bits[2];
- k.getData().put(key, s);
- return s.getTuples();
- }
- }
- }
- }
-
- public static double findStandardDeviation(ArrayList<Integer> array)
- {
- double mean = findMean(array);
- double d1 = 0;
- double d2 = 0;
- double sum = 0;
- for(int i = 0; i < array.size(); i++)
- {
- d2 = (mean - array.get(i))*(mean - array.get(i));
- d1 = d2 + d1;
- }
- return Math.sqrt((d1/(array.size()-1)));
- }
-
- public static double findMean(ArrayList<Integer> array)
- {
- double total = 0;
- for(int i = 0; i < array.size(); i++)
- {
- total = total + array.get(i);
- }
- return total/array.size();
- }
-
-
-
-
-}
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.2.xml
Fri Mar 1 10:09:26 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.2.xml
Wed Mar 6 09:21:27 2013
@@ -18,7 +18,7 @@
<sites>10,5</sites>
</extent>
<extent name="D">
- <sites>1,9</sites>
+ <sites>9</sites>
</extent>
</extents>
</sensor_network>
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.3.xml
Fri Mar 1 10:09:26 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.3.xml
Wed Mar 6 09:21:27 2013
@@ -18,7 +18,7 @@
<sites>10,5</sites>
</extent>
<extent name="D">
- <sites>1,9</sites>
+ <sites>9</sites>
</extent>
</extents>
</sensor_network>
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.4.xml
Fri Mar 1 10:09:26 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.4.xml
Wed Mar 6 09:21:27 2013
@@ -18,7 +18,7 @@
<sites>10,5</sites>
</extent>
<extent name="D">
- <sites>1,9</sites>
+ <sites>9</sites>
</extent>
</extents>
</sensor_network>
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.5.xml
Fri Mar 1 10:09:26 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/physicalSchema_query64.5.xml
Wed Mar 6 09:21:27 2013
@@ -18,7 +18,7 @@
<sites>10,5</sites>
</extent>
<extent name="D">
- <sites>1,9</sites>
+ <sites>9</sites>
</extent>
</extents>
</sensor_network>
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.2.properties
Fri Mar 1 10:09:26 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.2.properties
Wed Mar 6 09:21:27 2013
@@ -54,7 +54,7 @@
compiler.allow_discontinuous_sensing = true
# Location of the logical schema
-logical_schema = logicalSchema_query69.2.xml
+logical_schema = logicalSchema_query69.xml
# Location of the physical schema
physical_schema = physicalSchema_query69.2.xml
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.3.properties
Fri Mar 1 10:09:26 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.3.properties
Wed Mar 6 09:21:27 2013
@@ -54,7 +54,7 @@
compiler.allow_discontinuous_sensing = true
# Location of the logical schema
-logical_schema = logicalSchema_query69.3.xml
+logical_schema = logicalSchema_query69.xml
# Location of the physical schema
physical_schema = physicalSchema_query69.3.xml
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.4.properties
Fri Mar 1 10:09:26 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.4.properties
Wed Mar 6 09:21:27 2013
@@ -54,7 +54,7 @@
compiler.allow_discontinuous_sensing = true
# Location of the logical schema
-logical_schema = logicalSchema_query69.4.xml
+logical_schema = logicalSchema_query69.xml
# Location of the physical schema
physical_schema = physicalSchema_query69.4.xml
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.5.properties
Fri Mar 1 10:09:26 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/snee69.5.properties
Wed Mar 6 09:21:27 2013
@@ -54,7 +54,7 @@
compiler.allow_discontinuous_sensing = true
# Location of the logical schema
-logical_schema = logicalSchema_query69.5.xml
+logical_schema = logicalSchema_query69.xml
# Location of the physical schema
physical_schema = physicalSchema_query69.5.xml
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/top60.4.xml
Mon Jan 28 04:05:12 2013
+++
/branches/alan_2012_07_19_unreliableChannels/clients/reliable-channel-client/src/main/resources/condorDone/top60.4.xml
Wed Mar 6 09:21:27 2013
@@ -235,7 +235,7 @@
<radio-link source="29" dest="8" bidirectional="true" energy="254.0"
time="5.9" radio-loss="0"/>
<radio-link source="29" dest="27" bidirectional="true" energy="254.0"
time="5.9" radio-loss="0"/>
<radio-link source="29" dest="28" bidirectional="true" energy="254.0"
time="5.9" radio-loss="0"/>
-<radio-link source="29" dest="5" bidirectional="true" energy="22.0"
time="9.0" radio-loss="0"/>
+<radio-link source="29" dest="5" bidirectional="true" energy="254.0"
time="9.0" radio-loss="0"/>
<radio-link source="29" dest="31" bidirectional="true" energy="132.0"
time="0.9" radio-loss="0"/>
<radio-link source="29" dest="32" bidirectional="true" energy="132.0"
time="0.9" radio-loss="0"/>
<radio-link source="29" dest="33" bidirectional="true" energy="132.0"
time="0.9" radio-loss="0"/>
@@ -248,7 +248,7 @@
<radio-link source="1" dest="8" bidirectional="true" energy="11.0"
time="10.0" radio-loss="0"/>
<radio-link source="1" dest="27" bidirectional="true" energy="66.0"
time="10.0" radio-loss="0"/>
<radio-link source="1" dest="28" bidirectional="true" energy="66.0"
time="10.0" radio-loss="0"/>
-<radio-link source="1" dest="29" bidirectional="true" energy="66.0"
time="10.0" radio-loss="0"/>
+<radio-link source="1" dest="29" bidirectional="true" energy="254.0"
time="10.0" radio-loss="0"/>
<radio-link source="1" dest="30" bidirectional="true" energy="66.0"
time="10.0" radio-loss="0"/>
<radio-link source="1" dest="5" bidirectional="true" energy="252.0"
time="59.0" radio-loss="0"/>
<radio-link source="1" dest="31" bidirectional="true" energy="254.0"
time="5.9" radio-loss="0"/>
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/snee-wsn-manager/src/main/java/uk/ac/manchester/cs/snee/manager/executer/Executer.java
Mon Mar 4 13:20:13 2013
+++
/branches/alan_2012_07_19_unreliableChannels/snee-wsn-manager/src/main/java/uk/ac/manchester/cs/snee/manager/executer/Executer.java
Wed Mar 6 09:21:27 2013
@@ -150,8 +150,8 @@
tuplesReturnedFromEachTypeOfQEP.addWithDuplicates(type.RQEP,
tuplesReturned);
tuplesReturnedFromEachTypeOfQEP.addWithDuplicates(type.MAX,
maxTuplesReturnable);
tuplesReturnedFromEachTypeOfQEP.addWithDuplicates(type.AGGR,
aggreTuples);
- ChannelModelUtils utils = new
ChannelModelUtils(channelModel.getChannelModel(),
rQEP.getLogicalOverlayNetwork());
- utils.plotPacketRates(iteration, executerOutputFolder);
+ // ChannelModelUtils utils = new
ChannelModelUtils(channelModel.getChannelModel(),
rQEP.getLogicalOverlayNetwork());
+ //utils.plotPacketRates(iteration, executerOutputFolder);
channelModel.clearModel();
rQEP.getLogicalOverlayNetwork().removeClonedData();
}
=======================================
---
/branches/alan_2012_07_19_unreliableChannels/snee-wsn-manager/src/main/java/uk/ac/manchester/cs/snee/manager/planner/costbenifitmodel/model/channel/ChannelModelSite.java
Tue Mar 5 10:56:33 2013
+++
/branches/alan_2012_07_19_unreliableChannels/snee-wsn-manager/src/main/java/uk/ac/manchester/cs/snee/manager/planner/costbenifitmodel/model/channel/ChannelModelSite.java
Wed Mar 6 09:21:27 2013
@@ -592,7 +592,7 @@
ChannelModelSite.aggregationTupleTracker.get(op.getSite().getID());
if(currentSitesTracker == null)
currentSitesTracker = new HashMapList<Integer, Boolean>();
- HashMap<String, ArrayList<Boolean>> reducedArrivedpackets =
reduceArrivedPackets(op.getSite());
+ HashMap<String, ArrayList<Boolean>> reducedArrivedpackets =
reduceArrivedPackets(op.getSite(), this.arrivedPackets);
InstanceOperator firstInput = (InstanceOperator) op.getInput(0);
if(op.getSensornetOperator() instanceof SensornetAggrEvalOperator &&
firstInput.getSensornetOperator() instanceof
SensornetAggrMergeOperator)
@@ -696,10 +696,14 @@
Integer key = keys.next();
ArrayList<Boolean> bools = inputSitesTracker.get(key);
Iterator<Boolean> boolIterator = bools.iterator();
+ ArrayList<Boolean> receivedPackets =
reducedArrivedpackets.get(inputSite.getID());
+ Iterator<Boolean> receivedPacketIterator =
receivedPackets.iterator();
while(boolIterator.hasNext())
{
Boolean bool = boolIterator.next();
- currentSitesTracker.addWithDuplicates(key, bool);
+ Boolean recieved = receivedPacketIterator.next();
+ if(recieved)
+ currentSitesTracker.addWithDuplicates(key, bool);
}
}
}
@@ -713,10 +717,14 @@
Integer key = keys.next();
ArrayList<Boolean> bools = inputSitesTracker.get(key);
Iterator<Boolean> boolIterator = bools.iterator();
+ ArrayList<Boolean> receivedPackets =
reducedArrivedpackets.get(inputSite.getID());
+ Iterator<Boolean> receivedPacketIterator =
receivedPackets.iterator();
while(boolIterator.hasNext())
{
Boolean bool = boolIterator.next();
- currentSitesTracker.addWithDuplicates(key, bool);
+ Boolean recieved = receivedPacketIterator.next();
+ if(recieved)
+ currentSitesTracker.addWithDuplicates(key, bool);
}
}
}
@@ -725,26 +733,14 @@
ChannelModelSite.aggregationTupleTracker.put(op.getSite().getID(),
currentSitesTracker);
}
}
-
- if(op.getSensornetOperator() instanceof SensornetAggrEvalOperator)
- {
- int count = 0;
- Iterator<Integer> keys = currentSitesTracker.keySet().iterator();
- while(keys.hasNext())
- {
- Integer key = keys.next();
- Iterator<Boolean> values = currentSitesTracker.get(key).iterator();
- while(values.hasNext())
- {
- if(values.next())
- count++;
- }
- }
- ChannelModelSite.tuplesParticipatingInAggregation = count;
- }
}
- private HashMap<String, ArrayList<Boolean>> reduceArrivedPackets(Site
site)
+ private HashMap<String, ArrayList<Boolean>> getArrivedPackets()
+ {
+ return this.arrivedPackets;
+ }
+
+ private HashMap<String, ArrayList<Boolean>> reduceArrivedPackets(Site
site, HashMap<String, ArrayList<Boolean>> arrivedPackets)
{
HashMap<String, ArrayList<Boolean>> reducedArrivePackets = new
HashMap<String, ArrayList<Boolean>>();
ArrayList<Node> inputs = new ArrayList<Node>(site.getInputsList());
@@ -1366,8 +1362,82 @@
{
checkAggregationTupleTracker(op);
}
+ if(op.getSensornetOperator() instanceof SensornetDeliverOperator)
+ finishTracking(op);
}
}
+
+ private void finishTracking(InstanceOperator op)
+ {
+ HashMapList<Integer, Boolean> currentSitesTracker =
+ ChannelModelSite.aggregationTupleTracker.get(op.getSite().getID());
+ if(currentSitesTracker == null)
+ currentSitesTracker = new HashMapList<Integer, Boolean>();
+ ArrayList<InstanceOperator> operators =
+ overlayNetwork.getQep().getIOT().getOpInstances(op.getSite(),
TraversalOrder.POST_ORDER, true);
+ boolean evalLocatedOnsameSite = false;
+ Iterator<InstanceOperator> operatorIterator = operators.iterator();
+ while(operatorIterator.hasNext())
+ {
+ if(operatorIterator.next().getSensornetOperator() instanceof
SensornetAggrEvalOperator)
+ evalLocatedOnsameSite = true;
+ }
+ int count = 0;
+ if(evalLocatedOnsameSite)
+ {
+ Iterator<Integer> keys = currentSitesTracker.keySet().iterator();
+ while(keys.hasNext())
+ {
+ Integer key = keys.next();
+ Iterator<Boolean> values = currentSitesTracker.get(key).iterator();
+ while(values.hasNext())
+ {
+ if(values.next())
+ count++;
+ }
+ }
+ }
+ else
+ {
+ HashMap<String, ArrayList<Boolean>> reducedArrivedpackets =
reduceArrivedPackets(op.getSite(), this.arrivedPackets);
+ Iterator<Node> inputSites = op.getSite().getInputsList().iterator();
+ while(inputSites.hasNext())
+ {
+ Site inputSite = (Site) inputSites.next();
+ HashMapList<Integer, Boolean> inputSitesTracker =
+ ChannelModelSite.aggregationTupleTracker.get(inputSite.getID());
+ Iterator<Integer> keys = inputSitesTracker.keySet().iterator();
+ while(keys.hasNext())
+ {
+ Integer key = keys.next();
+ ArrayList<Boolean> bools = inputSitesTracker.get(key);
+ Iterator<Boolean> boolIterator = bools.iterator();
+ ArrayList<Boolean> receivedPackets =
reducedArrivedpackets.get(inputSite.getID());
+ Iterator<Boolean> receivedPacketIterator =
receivedPackets.iterator();
+ while(boolIterator.hasNext())
+ {
+ Boolean bool = boolIterator.next();
+ Boolean recieved = receivedPacketIterator.next();
+ if(recieved)
+ currentSitesTracker.addWithDuplicates(key, bool);
+ }
+ }
+ }
+ Iterator<Integer> keys = currentSitesTracker.keySet().iterator();
+ while(keys.hasNext())
+ {
+ Integer key = keys.next();
+ Iterator<Boolean> values = currentSitesTracker.get(key).iterator();
+ while(values.hasNext())
+ {
+ if(values.next())
+ count++;
+ }
+ }
+ }
+
+ ChannelModelSite.tuplesParticipatingInAggregation = count;
+ }
public static void resetAggreData()
{
Reply all
Reply to author
Forward
0 new messages