[MonetDB-users] select distinct ... where algorithm
I am seeing the following: select count(*) from f_sorted; +-----------+ | L7 | +===========+ | 102612097 | +-----------+ 1 tuple (0.988ms)
select count(*) from f_sorted where yyyymm='201110'; +----------+ | L10 | +==========+ | 23505343 | +----------+ 1 tuple (1.0s)
select count(distinct uuid) from f_sorted where yyyymm='201110'; +---------+ | L6 | +=========+ | 5941581 | +---------+ 1 tuple (23.8s)
Very fast thus far! However:
copy (select distinct(uuid) from f_sorted where yyyymm='201110') into '/home/user/filename' USING DELIMITERS ',','\n','"' NULL as 'null';
This has been running for hours and has yet to start writing to the file.
I get this when I explain the query: +----------------------------------------------------------------------------------------+ | mal | +========================================================================================+ | function user.s5_3{autoCommit=true}():void; | | X_2 := sql.mvc(); | | X_22:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0); | | X_23 := algebra.uselect(X_22,"201110":str); | | X_20:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2); | | X_24 := algebra.kdifference(X_23,X_20); | | X_21 := algebra.uselect(X_20,"201110":str); | | X_25 := algebra.kunion(X_24,X_21); | | X_18:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",1); | | X_19 := algebra.uselect(X_18,"201110":str); | | X_26 := algebra.kunion(X_25,X_19); | | X_16:bat[:oid,:oid] := sql.bind_dbat(X_2,"sys","f_sorted",1); | | X_17 := bat.reverse(X_16); | | X_27 := algebra.kdifference(X_26,X_17); | | X_28 := algebra.markT(X_27,0@0:oid); | | X_29 := bat.reverse(X_28); | | X_10:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0); | | X_8:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2); | | X_12 := algebra.kdifference(X_10,X_8); | | X_13 := algebra.kunion(X_12,X_8); | | X_5:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",1); | | X_14 := algebra.kunion(X_13,X_5); | | X_30 := algebra.leftjoin(X_29,X_14); | | (ext44,grp42) := group.done(X_30); | | X_33 := bat.mirror(ext44); | | X_34 := algebra.leftjoin(X_33,X_30); | | X_35 := sql.resultSet(1,1,X_34); | | sql.rsColumn(X_35,"sys.f_sorted","uuid":str,"varchar",2048,0,X_34); | | X_43 := io.stdout(); | | sql.exportResult(X_43,X_35); | | end s5_3; | +----------------------------------------------------------------------------------------+ 31 tuples (1.350ms)
Is it doing something wrong? I don't expect the query to take so long (hours) to produce the output, especially since the distinct count is also very fast.
The copy-into *seems* to be irrelevant to the problem, but I decided to include it just in case, as that's how I am using the query.
select count(distinct uuid) from f_sorted where yyyymm='201110'; +---------+ | L6 | +=========+ | 5941581 | +---------+ 1 tuple (23.8s)
Very fast thus far! However:
copy (select distinct(uuid) from f_sorted where yyyymm='201110') into '/home/user/filename' USING DELIMITERS ',','\n','"' NULL as 'null';
This has been running for hours and has yet to start writing to the file.
Indeed, it should finish quickly. This indicates that there other issues involved in your environment, e.g. competition of other resource hungry processors. Or, the (dbfarm) disk on which you want to write is (almost) full.
Could you possibly also share the EXPLAIN, or even TRACE of your count(distinct uuid) query with us?
Thanks!
Stefan
On Thu, Feb 09, 2012 at 05:04:51PM -0800, zack_pcd wrote:
I am seeing the following: select count(*) from f_sorted; +-----------+ | L7 | +===========+ | 102612097 | +-----------+ 1 tuple (0.988ms)
select count(*) from f_sorted where yyyymm='201110'; +----------+ | L10 | +==========+ | 23505343 | +----------+ 1 tuple (1.0s)
select count(distinct uuid) from f_sorted where yyyymm='201110'; +---------+ | L6 | +=========+ | 5941581 | +---------+ 1 tuple (23.8s)
Very fast thus far! However:
copy (select distinct(uuid) from f_sorted where yyyymm='201110') into '/home/user/filename' USING DELIMITERS ',','\n','"' NULL as 'null';
This has been running for hours and has yet to start writing to the file.
I get this when I explain the query: +----------------------------------------------------------------------------------------+ | mal | +========================================================================================+ | function user.s5_3{autoCommit=true}():void; | | X_2 := sql.mvc(); | | X_22:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0); | | X_23 := algebra.uselect(X_22,"201110":str); | | X_20:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2); | | X_24 := algebra.kdifference(X_23,X_20); | | X_21 := algebra.uselect(X_20,"201110":str); | | X_25 := algebra.kunion(X_24,X_21); | | X_18:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",1); | | X_19 := algebra.uselect(X_18,"201110":str); | | X_26 := algebra.kunion(X_25,X_19); | | X_16:bat[:oid,:oid] := sql.bind_dbat(X_2,"sys","f_sorted",1); | | X_17 := bat.reverse(X_16); | | X_27 := algebra.kdifference(X_26,X_17); | | X_28 := algebra.markT(X_27,0@0:oid); | | X_29 := bat.reverse(X_28); | | X_10:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0); | | X_8:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2); | | X_12 := algebra.kdifference(X_10,X_8); | | X_13 := algebra.kunion(X_12,X_8); | | X_5:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",1); | | X_14 := algebra.kunion(X_13,X_5); | | X_30 := algebra.leftjoin(X_29,X_14); | | (ext44,grp42) := group.done(X_30); | | X_33 := bat.mirror(ext44); | | X_34 := algebra.leftjoin(X_33,X_30); | | X_35 := sql.resultSet(1,1,X_34); | | sql.rsColumn(X_35,"sys.f_sorted","uuid":str,"varchar",2048,0,X_34); | | X_43 := io.stdout(); | | sql.exportResult(X_43,X_35); | | end s5_3; | +----------------------------------------------------------------------------------------+ 31 tuples (1.350ms)
Is it doing something wrong? I don't expect the query to take so long (hours) to produce the output, especially since the distinct count is also very fast.
The copy-into *seems* to be irrelevant to the problem, but I decided to include it just in case, as that's how I am using the query. -- View this message in context: http://old.nabble.com/select-distinct-...-where-algorithm-tp33297578p3329757... Sent from the monetdb-users mailing list archive at Nabble.com.
Virtualization & Cloud Management Using Capacity Planning Cloud computing makes use of virtualization - but cloud computing also focuses on allowing computing to be delivered as a service. http://www.accelacomm.com/jaw/sfnl/114/51521223/ _______________________________________________ MonetDB-users mailing list MonetDB-users@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/monetdb-users
The copy into query finished in 317 minutes. The volume we use is 63% full. However the copy-into query does not start writing in the first few hours (I don't see the file getting created). In fact, I see almost no disk usage, and the query is only using 1 or 2 cores out of 32 (nthreads=32). I'll try to run a trace of the copy-into as well but that will take a while. I'm using the default_pipe in the dec2011 release. I don't think I've actually changed any of the default settings.
Trace and explain of the count distinct query:
sql>explain select count(distinct uuid) from f_sorted where yyyymm='201110'; +-------------------------------------------------------------------------------------+ | mal | +=====================================================================================+ | function user.s7_1{autoCommit=true}():void; | | X_2 := sql.mvc(); | | X_23:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0); | | X_25 := algebra.uselect(X_23,"201110":str); | | X_21:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2); | | X_26 := algebra.kdifference(X_25,X_21); | | X_22 := algebra.uselect(X_21,"201110":str); | | X_27 := algebra.kunion(X_26,X_22); | | X_19:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",1); | | X_20 := algebra.uselect(X_19,"201110":str); | | X_28 := algebra.kunion(X_27,X_20); | | X_16:bat[:oid,:oid] := sql.bind_dbat(X_2,"sys","f_sorted",1); | | X_17 := bat.reverse(X_16); | | X_29 := algebra.kdifference(X_28,X_17); | | X_30 := algebra.markT(X_29,0@0:oid); | | X_31 := bat.reverse(X_30); | | X_10:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0); | | X_8:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2); | | X_12 := algebra.kdifference(X_10,X_8); | | X_13 := algebra.kunion(X_12,X_8); | | X_4:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",1); | | X_14 := algebra.kunion(X_13,X_4); | | X_32 := algebra.leftjoin(X_31,X_14); | | X_33 := algebra.selectNotNil(X_32); | | X_34 := bat.reverse(X_33); | | X_35 := algebra.kunique(X_34); | | X_36 := bat.reverse(X_35); | | X_37 := aggr.count(X_36); | | sql.exportValue(1,"sys.f_sorted","L7":str,"wrd",64,0,6,X_37,""); | | end s7_1; | +-------------------------------------------------------------------------------------+ 30 tuples (1.278ms) sql>trace select count(distinct uuid) from f_sorted where yyyymm='201110'; +---------+ | L10 | +=========+ | 5941581 | +---------+ 1 tuple (27.3s) +----------+--------------------------------------------------------------------------------------------------------------+ | ticks | stmt | +==========+==============================================================================================================+ | 6 | X_3 := sql.mvc(); | | 12 | X_23:bat[:oid,:str] =<tmp_7256>[102612097] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0); | | 2497718 | X_24=<tmp_7425>[23505343] := algebra.uselect(X_23=nil:bat[:oid,:str],A0="201110"); | | 21 | X_21:bat[:oid,:str] =<tmp_6530>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2); | | 28 | X_25=<tmp_7174>[23505343] := algebra.kdifference(X_24=nil,X_21=<tmp_6530>:bat[:oid,:str][0]); | | 29 | X_22=<tmp_7340>[0] := algebra.uselect(X_21=nil:bat[:oid,:str],A0="201110"); | | 10 | X_26=<tmp_7435>[23505343] := algebra.kunion(X_25=nil,X_22=nil); | | 5 | X_19:bat[:oid,:str] =<tmp_7013>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",1); | | 11 | X_20=<tmp_7174>[0] := algebra.uselect(X_19=nil:bat[:oid,:str],A0="201110"); | | 9 | X_27=<tmp_7340>[23505343] := algebra.kunion(X_26=nil,X_20=nil); | | 6 | X_17:bat[:oid,:oid] =<tmp_7003>[0] := sql.bind_dbat(X_3=0,"sys","f_sorted",1); | | 4 | X_18=<tmpr_7003>[0] := bat.reverse(X_17=nil:bat[:oid,:oid]); | | 5 | X_28=<tmp_7174>[23505343] := algebra.kdifference(X_27=nil,X_18=nil); | | 7 | X_29=<tmp_7340>[23505343] := algebra.markT(X_28=nil,0@0:oid); | | 3 | X_30=<tmpr_7340>[23505343] := bat.reverse(X_29=nil); | | 12 | X_11:bat[:oid,:str] =<tmp_7027>[102612097] := sql.bind(X_3=0,"sys","f_sorted","uuid",0); | | 3 | X_9:bat[:oid,:str] =<tmp_6530>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2); | | 9 | X_13=<tmp_7174>[102612097] := algebra.kdifference(X_11=nil:bat[:oid,:str],X_9=<tmp_6530>:bat[:oid,:str][0]); | | 9 | X_14=<tmp_7435>[102612097] := algebra.kunion(X_13=nil,X_9=nil:bat[:oid,:str]); | | 4 | X_5:bat[:oid,:str] =<tmp_7326>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",1); | | 7 | X_15=<tmp_7174>[102612097] := algebra.kunion(X_14=nil,X_5=nil:bat[:oid,:str]); | | 885318 | X_31=<tmp_7435>[23505343] := algebra.leftjoin(X_30=nil,X_15=nil); | | 12 | X_32=<tmp_7435>[23505343] := algebra.selectNotNil(X_31=nil); | | 4 | X_33=<tmpr_7435>[23505343] := bat.reverse(X_32=nil); | | 23833624 | X_34=<tmp_7174>[5941581] := algebra.kunique(X_33=nil); | | 14 | X_35=<tmpr_7174>[5941581] := bat.reverse(X_34=nil); | | 87995 | X_36 := aggr.count(X_35=nil); | | 25 | sql.exportValue(1,"sys.f_sorted","L10":str,"wrd",64,0,6,X_36=5941581:wrd,""); | | 27306480 | X_5:void := user.s8_1("201110"); | +----------+--------------------------------------------------------------------------------------------------------------+ 29 tuples (27.3s)
Stefan Manegold wrote:
Could you possibly also share the EXPLAIN, or even TRACE of your count(distinct uuid) query with us?
Thanks!
Stefan
On Thu, Feb 09, 2012 at 05:04:51PM -0800, zack_pcd wrote:
I am seeing the following: select count(*) from f_sorted; +-----------+ | L7 | +===========+ | 102612097 | +-----------+ 1 tuple (0.988ms)
select count(*) from f_sorted where yyyymm='201110'; +----------+ | L10 | +==========+ | 23505343 | +----------+ 1 tuple (1.0s)
select count(distinct uuid) from f_sorted where yyyymm='201110'; +---------+ | L6 | +=========+ | 5941581 | +---------+ 1 tuple (23.8s)
Very fast thus far! However:
copy (select distinct(uuid) from f_sorted where yyyymm='201110') into '/home/user/filename' USING DELIMITERS ',','\n','"' NULL as 'null';
This has been running for hours and has yet to start writing to the file.
I get this when I explain the query: +----------------------------------------------------------------------------------------+ | mal | +========================================================================================+ | function user.s5_3{autoCommit=true}():void; | | X_2 := sql.mvc(); | | X_22:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0); | | X_23 := algebra.uselect(X_22,"201110":str); | | X_20:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2); | | X_24 := algebra.kdifference(X_23,X_20); | | X_21 := algebra.uselect(X_20,"201110":str); | | X_25 := algebra.kunion(X_24,X_21); | | X_18:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",1); | | X_19 := algebra.uselect(X_18,"201110":str); | | X_26 := algebra.kunion(X_25,X_19); | | X_16:bat[:oid,:oid] := sql.bind_dbat(X_2,"sys","f_sorted",1); | | X_17 := bat.reverse(X_16); | | X_27 := algebra.kdifference(X_26,X_17); | | X_28 := algebra.markT(X_27,0@0:oid); | | X_29 := bat.reverse(X_28); | | X_10:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0); | | X_8:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2); | | X_12 := algebra.kdifference(X_10,X_8); | | X_13 := algebra.kunion(X_12,X_8); | | X_5:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",1); | | X_14 := algebra.kunion(X_13,X_5); | | X_30 := algebra.leftjoin(X_29,X_14); | | (ext44,grp42) := group.done(X_30); | | X_33 := bat.mirror(ext44); | | X_34 := algebra.leftjoin(X_33,X_30); | | X_35 := sql.resultSet(1,1,X_34); | | sql.rsColumn(X_35,"sys.f_sorted","uuid":str,"varchar",2048,0,X_34); | | X_43 := io.stdout(); | | sql.exportResult(X_43,X_35); | | end s5_3; | +----------------------------------------------------------------------------------------+ 31 tuples (1.350ms)
Is it doing something wrong? I don't expect the query to take so long (hours) to produce the output, especially since the distinct count is also very fast.
The copy-into *seems* to be irrelevant to the problem, but I decided to include it just in case, as that's how I am using the query. -- View this message in context: http://old.nabble.com/select-distinct-...-where-algorithm-tp33297578p3329757... Sent from the monetdb-users mailing list archive at Nabble.com.
Virtualization & Cloud Management Using Capacity Planning Cloud computing makes use of virtualization - but cloud computing also focuses on allowing computing to be delivered as a service. http://www.accelacomm.com/jaw/sfnl/114/51521223/ _______________________________________________ MonetDB-users mailing list MonetDB-users@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/monetdb-users
-- | Stefan.Manegold @ CWI.nl | DB Architectures (INS1) | | http://CWI.nl/~manegold/ | Science Park 123 (L321) | | Tel.: +31 (0)20 592-4212 | 1098 XG Amsterdam (NL) |
Virtualization & Cloud Management Using Capacity Planning Cloud computing makes use of virtualization - but cloud computing also focuses on allowing computing to be delivered as a service. http://www.accelacomm.com/jaw/sfnl/114/51521223/ _______________________________________________ MonetDB-users mailing list MonetDB-users@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/monetdb-users
Hi Zack,
thank you very much.
The fact that MonetDB only uses 1-2 cores (with this query) is to be expected, as we currently cannot run "distinct" efficiently i parallel.
Also the fact that MonetDB writes the result only at the end is to be expected due to MonetDB's operator-at-a-time "bulk processing" execution paradigm.
For analyzing this issue in more detail, it would be very helpful for us, if you could also re-run you copy into query with TRACE and send us the result --- provided you could block you machine for another 5-6 hours ...
Thanks!
Stefan
On Fri, Feb 10, 2012 at 09:51:45AM -0800, zack_pcd wrote:
The copy into query finished in 317 minutes. The volume we use is 63% full. However the copy-into query does not start writing in the first few hours (I don't see the file getting created). In fact, I see almost no disk usage, and the query is only using 1 or 2 cores out of 32 (nthreads=32). I'll try to run a trace of the copy-into as well but that will take a while. I'm using the default_pipe in the dec2011 release. I don't think I've actually changed any of the default settings.
Trace and explain of the count distinct query:
sql>explain select count(distinct uuid) from f_sorted where yyyymm='201110'; +-------------------------------------------------------------------------------------+ | mal | +=====================================================================================+ | function user.s7_1{autoCommit=true}():void; | | X_2 := sql.mvc(); | | X_23:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0); | | X_25 := algebra.uselect(X_23,"201110":str); | | X_21:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2); | | X_26 := algebra.kdifference(X_25,X_21); | | X_22 := algebra.uselect(X_21,"201110":str); | | X_27 := algebra.kunion(X_26,X_22); | | X_19:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",1); | | X_20 := algebra.uselect(X_19,"201110":str); | | X_28 := algebra.kunion(X_27,X_20); | | X_16:bat[:oid,:oid] := sql.bind_dbat(X_2,"sys","f_sorted",1); | | X_17 := bat.reverse(X_16); | | X_29 := algebra.kdifference(X_28,X_17); | | X_30 := algebra.markT(X_29,0@0:oid); | | X_31 := bat.reverse(X_30); | | X_10:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0); | | X_8:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2); | | X_12 := algebra.kdifference(X_10,X_8); | | X_13 := algebra.kunion(X_12,X_8); | | X_4:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",1); | | X_14 := algebra.kunion(X_13,X_4); | | X_32 := algebra.leftjoin(X_31,X_14); | | X_33 := algebra.selectNotNil(X_32); | | X_34 := bat.reverse(X_33); | | X_35 := algebra.kunique(X_34); | | X_36 := bat.reverse(X_35); | | X_37 := aggr.count(X_36); | | sql.exportValue(1,"sys.f_sorted","L7":str,"wrd",64,0,6,X_37,""); | | end s7_1; | +-------------------------------------------------------------------------------------+ 30 tuples (1.278ms) sql>trace select count(distinct uuid) from f_sorted where yyyymm='201110'; +---------+ | L10 | +=========+ | 5941581 | +---------+ 1 tuple (27.3s) +----------+--------------------------------------------------------------------------------------------------------------+ | ticks | stmt | +==========+==============================================================================================================+ | 6 | X_3 := sql.mvc(); | | 12 | X_23:bat[:oid,:str] =<tmp_7256>[102612097] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0); | | 2497718 | X_24=<tmp_7425>[23505343] := algebra.uselect(X_23=nil:bat[:oid,:str],A0="201110"); | | 21 | X_21:bat[:oid,:str] =<tmp_6530>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2); | | 28 | X_25=<tmp_7174>[23505343] := algebra.kdifference(X_24=nil,X_21=<tmp_6530>:bat[:oid,:str][0]); | | 29 | X_22=<tmp_7340>[0] := algebra.uselect(X_21=nil:bat[:oid,:str],A0="201110"); | | 10 | X_26=<tmp_7435>[23505343] := algebra.kunion(X_25=nil,X_22=nil); | | 5 | X_19:bat[:oid,:str] =<tmp_7013>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",1); | | 11 | X_20=<tmp_7174>[0] := algebra.uselect(X_19=nil:bat[:oid,:str],A0="201110"); | | 9 | X_27=<tmp_7340>[23505343] := algebra.kunion(X_26=nil,X_20=nil); | | 6 | X_17:bat[:oid,:oid] =<tmp_7003>[0] := sql.bind_dbat(X_3=0,"sys","f_sorted",1); | | 4 | X_18=<tmpr_7003>[0] := bat.reverse(X_17=nil:bat[:oid,:oid]); | | 5 | X_28=<tmp_7174>[23505343] := algebra.kdifference(X_27=nil,X_18=nil); | | 7 | X_29=<tmp_7340>[23505343] := algebra.markT(X_28=nil,0@0:oid); | | 3 | X_30=<tmpr_7340>[23505343] := bat.reverse(X_29=nil); | | 12 | X_11:bat[:oid,:str] =<tmp_7027>[102612097] := sql.bind(X_3=0,"sys","f_sorted","uuid",0); | | 3 | X_9:bat[:oid,:str] =<tmp_6530>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2); | | 9 | X_13=<tmp_7174>[102612097] := algebra.kdifference(X_11=nil:bat[:oid,:str],X_9=<tmp_6530>:bat[:oid,:str][0]); | | 9 | X_14=<tmp_7435>[102612097] := algebra.kunion(X_13=nil,X_9=nil:bat[:oid,:str]); | | 4 | X_5:bat[:oid,:str] =<tmp_7326>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",1); | | 7 | X_15=<tmp_7174>[102612097] := algebra.kunion(X_14=nil,X_5=nil:bat[:oid,:str]); | | 885318 | X_31=<tmp_7435>[23505343] := algebra.leftjoin(X_30=nil,X_15=nil); | | 12 | X_32=<tmp_7435>[23505343] := algebra.selectNotNil(X_31=nil); | | 4 | X_33=<tmpr_7435>[23505343] := bat.reverse(X_32=nil); | | 23833624 | X_34=<tmp_7174>[5941581] := algebra.kunique(X_33=nil); | | 14 | X_35=<tmpr_7174>[5941581] := bat.reverse(X_34=nil); | | 87995 | X_36 := aggr.count(X_35=nil); | | 25 | sql.exportValue(1,"sys.f_sorted","L10":str,"wrd",64,0,6,X_36=5941581:wrd,""); | | 27306480 | X_5:void := user.s8_1("201110"); | +----------+--------------------------------------------------------------------------------------------------------------+ 29 tuples (27.3s)
Stefan Manegold wrote:
Could you possibly also share the EXPLAIN, or even TRACE of your count(distinct uuid) query with us?
Thanks!
Stefan
On Thu, Feb 09, 2012 at 05:04:51PM -0800, zack_pcd wrote:
I am seeing the following: select count(*) from f_sorted; +-----------+ | L7 | +===========+ | 102612097 | +-----------+ 1 tuple (0.988ms)
select count(*) from f_sorted where yyyymm='201110'; +----------+ | L10 | +==========+ | 23505343 | +----------+ 1 tuple (1.0s)
select count(distinct uuid) from f_sorted where yyyymm='201110'; +---------+ | L6 | +=========+ | 5941581 | +---------+ 1 tuple (23.8s)
Very fast thus far! However:
copy (select distinct(uuid) from f_sorted where yyyymm='201110') into '/home/user/filename' USING DELIMITERS ',','\n','"' NULL as 'null';
This has been running for hours and has yet to start writing to the file.
I get this when I explain the query: +----------------------------------------------------------------------------------------+ | mal | +========================================================================================+ | function user.s5_3{autoCommit=true}():void; | | X_2 := sql.mvc(); | | X_22:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0); | | X_23 := algebra.uselect(X_22,"201110":str); | | X_20:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2); | | X_24 := algebra.kdifference(X_23,X_20); | | X_21 := algebra.uselect(X_20,"201110":str); | | X_25 := algebra.kunion(X_24,X_21); | | X_18:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",1); | | X_19 := algebra.uselect(X_18,"201110":str); | | X_26 := algebra.kunion(X_25,X_19); | | X_16:bat[:oid,:oid] := sql.bind_dbat(X_2,"sys","f_sorted",1); | | X_17 := bat.reverse(X_16); | | X_27 := algebra.kdifference(X_26,X_17); | | X_28 := algebra.markT(X_27,0@0:oid); | | X_29 := bat.reverse(X_28); | | X_10:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0); | | X_8:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2); | | X_12 := algebra.kdifference(X_10,X_8); | | X_13 := algebra.kunion(X_12,X_8); | | X_5:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",1); | | X_14 := algebra.kunion(X_13,X_5); | | X_30 := algebra.leftjoin(X_29,X_14); | | (ext44,grp42) := group.done(X_30); | | X_33 := bat.mirror(ext44); | | X_34 := algebra.leftjoin(X_33,X_30); | | X_35 := sql.resultSet(1,1,X_34); | | sql.rsColumn(X_35,"sys.f_sorted","uuid":str,"varchar",2048,0,X_34); | | X_43 := io.stdout(); | | sql.exportResult(X_43,X_35); | | end s5_3; | +----------------------------------------------------------------------------------------+ 31 tuples (1.350ms)
Is it doing something wrong? I don't expect the query to take so long (hours) to produce the output, especially since the distinct count is also very fast.
The copy-into *seems* to be irrelevant to the problem, but I decided to include it just in case, as that's how I am using the query. -- View this message in context: http://old.nabble.com/select-distinct-...-where-algorithm-tp33297578p3329757... Sent from the monetdb-users mailing list archive at Nabble.com.
Virtualization & Cloud Management Using Capacity Planning Cloud computing makes use of virtualization - but cloud computing also focuses on allowing computing to be delivered as a service. http://www.accelacomm.com/jaw/sfnl/114/51521223/ _______________________________________________ MonetDB-users mailing list MonetDB-users@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/monetdb-users
-- | Stefan.Manegold @ CWI.nl | DB Architectures (INS1) | | http://CWI.nl/~manegold/ | Science Park 123 (L321) | | Tel.: +31 (0)20 592-4212 | 1098 XG Amsterdam (NL) |
Virtualization & Cloud Management Using Capacity Planning Cloud computing makes use of virtualization - but cloud computing also focuses on allowing computing to be delivered as a service. http://www.accelacomm.com/jaw/sfnl/114/51521223/ _______________________________________________ MonetDB-users mailing list MonetDB-users@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/monetdb-users
-- View this message in context: http://old.nabble.com/select-distinct-...-where-algorithm-tp33297578p3330212... Sent from the monetdb-users mailing list archive at Nabble.com.
Virtualization & Cloud Management Using Capacity Planning Cloud computing makes use of virtualization - but cloud computing also focuses on allowing computing to be delivered as a service. http://www.accelacomm.com/jaw/sfnl/114/51521223/ _______________________________________________ MonetDB-users mailing list MonetDB-users@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/monetdb-users
On Fri, Feb 10, 2012 at 09:51:45AM -0800, zack_pcd wrote:
The copy into query finished in 317 minutes. The volume we use is 63% full. However the copy-into query does not start writing in the first few hours (I don't see the file getting created). In fact, I see almost no disk usage, and the query is only using 1 or 2 cores out of 32 (nthreads=32). I'll try to run a trace of the copy-into as well but that will take a while. I'm using the default_pipe in the dec2011 release. I don't think I've actually changed any of the default settings.
Trace and explain of the count distinct query:
Could you also send the plan and explain of the copy into statements?
Niels
sql>explain select count(distinct uuid) from f_sorted where yyyymm='201110'; +-------------------------------------------------------------------------------------+ | mal | +=====================================================================================+ | function user.s7_1{autoCommit=true}():void; | | X_2 := sql.mvc(); | | X_23:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0); | | X_25 := algebra.uselect(X_23,"201110":str); | | X_21:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2); | | X_26 := algebra.kdifference(X_25,X_21); | | X_22 := algebra.uselect(X_21,"201110":str); | | X_27 := algebra.kunion(X_26,X_22); | | X_19:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",1); | | X_20 := algebra.uselect(X_19,"201110":str); | | X_28 := algebra.kunion(X_27,X_20); | | X_16:bat[:oid,:oid] := sql.bind_dbat(X_2,"sys","f_sorted",1); | | X_17 := bat.reverse(X_16); | | X_29 := algebra.kdifference(X_28,X_17); | | X_30 := algebra.markT(X_29,0@0:oid); | | X_31 := bat.reverse(X_30); | | X_10:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0); | | X_8:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2); | | X_12 := algebra.kdifference(X_10,X_8); | | X_13 := algebra.kunion(X_12,X_8); | | X_4:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",1); | | X_14 := algebra.kunion(X_13,X_4); | | X_32 := algebra.leftjoin(X_31,X_14); | | X_33 := algebra.selectNotNil(X_32); | | X_34 := bat.reverse(X_33); | | X_35 := algebra.kunique(X_34); | | X_36 := bat.reverse(X_35); | | X_37 := aggr.count(X_36); | | sql.exportValue(1,"sys.f_sorted","L7":str,"wrd",64,0,6,X_37,""); | | end s7_1; | +-------------------------------------------------------------------------------------+ 30 tuples (1.278ms) sql>trace select count(distinct uuid) from f_sorted where yyyymm='201110'; +---------+ | L10 | +=========+ | 5941581 | +---------+ 1 tuple (27.3s) +----------+--------------------------------------------------------------------------------------------------------------+ | ticks | stmt | +==========+==============================================================================================================+ | 6 | X_3 := sql.mvc(); | | 12 | X_23:bat[:oid,:str] =<tmp_7256>[102612097] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0); | | 2497718 | X_24=<tmp_7425>[23505343] := algebra.uselect(X_23=nil:bat[:oid,:str],A0="201110"); | | 21 | X_21:bat[:oid,:str] =<tmp_6530>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2); | | 28 | X_25=<tmp_7174>[23505343] := algebra.kdifference(X_24=nil,X_21=<tmp_6530>:bat[:oid,:str][0]); | | 29 | X_22=<tmp_7340>[0] := algebra.uselect(X_21=nil:bat[:oid,:str],A0="201110"); | | 10 | X_26=<tmp_7435>[23505343] := algebra.kunion(X_25=nil,X_22=nil); | | 5 | X_19:bat[:oid,:str] =<tmp_7013>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",1); | | 11 | X_20=<tmp_7174>[0] := algebra.uselect(X_19=nil:bat[:oid,:str],A0="201110"); | | 9 | X_27=<tmp_7340>[23505343] := algebra.kunion(X_26=nil,X_20=nil); | | 6 | X_17:bat[:oid,:oid] =<tmp_7003>[0] := sql.bind_dbat(X_3=0,"sys","f_sorted",1); | | 4 | X_18=<tmpr_7003>[0] := bat.reverse(X_17=nil:bat[:oid,:oid]); | | 5 | X_28=<tmp_7174>[23505343] := algebra.kdifference(X_27=nil,X_18=nil); | | 7 | X_29=<tmp_7340>[23505343] := algebra.markT(X_28=nil,0@0:oid); | | 3 | X_30=<tmpr_7340>[23505343] := bat.reverse(X_29=nil); | | 12 | X_11:bat[:oid,:str] =<tmp_7027>[102612097] := sql.bind(X_3=0,"sys","f_sorted","uuid",0); | | 3 | X_9:bat[:oid,:str] =<tmp_6530>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2); | | 9 | X_13=<tmp_7174>[102612097] := algebra.kdifference(X_11=nil:bat[:oid,:str],X_9=<tmp_6530>:bat[:oid,:str][0]); | | 9 | X_14=<tmp_7435>[102612097] := algebra.kunion(X_13=nil,X_9=nil:bat[:oid,:str]); | | 4 | X_5:bat[:oid,:str] =<tmp_7326>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",1); | | 7 | X_15=<tmp_7174>[102612097] := algebra.kunion(X_14=nil,X_5=nil:bat[:oid,:str]); | | 885318 | X_31=<tmp_7435>[23505343] := algebra.leftjoin(X_30=nil,X_15=nil); | | 12 | X_32=<tmp_7435>[23505343] := algebra.selectNotNil(X_31=nil); | | 4 | X_33=<tmpr_7435>[23505343] := bat.reverse(X_32=nil); | | 23833624 | X_34=<tmp_7174>[5941581] := algebra.kunique(X_33=nil); | | 14 | X_35=<tmpr_7174>[5941581] := bat.reverse(X_34=nil); | | 87995 | X_36 := aggr.count(X_35=nil); | | 25 | sql.exportValue(1,"sys.f_sorted","L10":str,"wrd",64,0,6,X_36=5941581:wrd,""); | | 27306480 | X_5:void := user.s8_1("201110"); | +----------+--------------------------------------------------------------------------------------------------------------+ 29 tuples (27.3s)
Stefan Manegold wrote:
Could you possibly also share the EXPLAIN, or even TRACE of your count(distinct uuid) query with us?
Thanks!
Stefan
On Thu, Feb 09, 2012 at 05:04:51PM -0800, zack_pcd wrote:
I am seeing the following: select count(*) from f_sorted; +-----------+ | L7 | +===========+ | 102612097 | +-----------+ 1 tuple (0.988ms)
select count(*) from f_sorted where yyyymm='201110'; +----------+ | L10 | +==========+ | 23505343 | +----------+ 1 tuple (1.0s)
select count(distinct uuid) from f_sorted where yyyymm='201110'; +---------+ | L6 | +=========+ | 5941581 | +---------+ 1 tuple (23.8s)
Very fast thus far! However:
copy (select distinct(uuid) from f_sorted where yyyymm='201110') into '/home/user/filename' USING DELIMITERS ',','\n','"' NULL as 'null';
This has been running for hours and has yet to start writing to the file.
I get this when I explain the query: +----------------------------------------------------------------------------------------+ | mal | +========================================================================================+ | function user.s5_3{autoCommit=true}():void; | | X_2 := sql.mvc(); | | X_22:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0); | | X_23 := algebra.uselect(X_22,"201110":str); | | X_20:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2); | | X_24 := algebra.kdifference(X_23,X_20); | | X_21 := algebra.uselect(X_20,"201110":str); | | X_25 := algebra.kunion(X_24,X_21); | | X_18:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",1); | | X_19 := algebra.uselect(X_18,"201110":str); | | X_26 := algebra.kunion(X_25,X_19); | | X_16:bat[:oid,:oid] := sql.bind_dbat(X_2,"sys","f_sorted",1); | | X_17 := bat.reverse(X_16); | | X_27 := algebra.kdifference(X_26,X_17); | | X_28 := algebra.markT(X_27,0@0:oid); | | X_29 := bat.reverse(X_28); | | X_10:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0); | | X_8:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2); | | X_12 := algebra.kdifference(X_10,X_8); | | X_13 := algebra.kunion(X_12,X_8); | | X_5:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",1); | | X_14 := algebra.kunion(X_13,X_5); | | X_30 := algebra.leftjoin(X_29,X_14); | | (ext44,grp42) := group.done(X_30); | | X_33 := bat.mirror(ext44); | | X_34 := algebra.leftjoin(X_33,X_30); | | X_35 := sql.resultSet(1,1,X_34); | | sql.rsColumn(X_35,"sys.f_sorted","uuid":str,"varchar",2048,0,X_34); | | X_43 := io.stdout(); | | sql.exportResult(X_43,X_35); | | end s5_3; | +----------------------------------------------------------------------------------------+ 31 tuples (1.350ms)
Is it doing something wrong? I don't expect the query to take so long (hours) to produce the output, especially since the distinct count is also very fast.
The copy-into *seems* to be irrelevant to the problem, but I decided to include it just in case, as that's how I am using the query. -- View this message in context: http://old.nabble.com/select-distinct-...-where-algorithm-tp33297578p3329757... Sent from the monetdb-users mailing list archive at Nabble.com.
Virtualization & Cloud Management Using Capacity Planning Cloud computing makes use of virtualization - but cloud computing also focuses on allowing computing to be delivered as a service. http://www.accelacomm.com/jaw/sfnl/114/51521223/ _______________________________________________ MonetDB-users mailing list MonetDB-users@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/monetdb-users
-- | Stefan.Manegold @ CWI.nl | DB Architectures (INS1) | | http://CWI.nl/~manegold/ | Science Park 123 (L321) | | Tel.: +31 (0)20 592-4212 | 1098 XG Amsterdam (NL) |
Virtualization & Cloud Management Using Capacity Planning Cloud computing makes use of virtualization - but cloud computing also focuses on allowing computing to be delivered as a service. http://www.accelacomm.com/jaw/sfnl/114/51521223/ _______________________________________________ MonetDB-users mailing list MonetDB-users@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/monetdb-users
-- View this message in context: http://old.nabble.com/select-distinct-...-where-algorithm-tp33297578p3330212... Sent from the monetdb-users mailing list archive at Nabble.com.
Virtualization & Cloud Management Using Capacity Planning Cloud computing makes use of virtualization - but cloud computing also focuses on allowing computing to be delivered as a service. http://www.accelacomm.com/jaw/sfnl/114/51521223/ _______________________________________________ MonetDB-users mailing list MonetDB-users@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/monetdb-users
Well, the trace/explain of the copy select distinct query certainly is much larger than the other traces:
trace copy (select distinct(uuid) from f_sorted where yyyymm='201110') into '/home/user/file' USING DELIMITERS ',','\n','"' NULL as 'null';
result: +-------------+-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+ | ticks | stmt | +=============+=====================================================================================================================================================================================+ | 5 | X_19 := nil:bat[:oid,:str]; | | 6 | X_3 := sql.mvc(); | | 61 | X_378:bat[:oid,:str] =<tmp_7316>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,0,32); | | 221 | X_268:bat[:oid,:str] =<tmp_7546>[3206629] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,31,32); | | 284 | X_154:bat[:oid,:str] =<tmpr_7524>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,29,32); | | 16 | X_462:bat[:oid,:str] =<tmp_7614>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,25,32); | | 176 | X_368:bat[:oid,:str] =<tmpr_7471>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,29,32); | | 192 | X_145:bat[:oid,:str] =<tmpr_7515>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,26,32); | | 21 | X_138:bat[:oid,:str] =<tmpr_7555>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,24,32); | | 424 | X_251:bat[:oid,:str] =<tmp_7606>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,26,32); | | 227 | X_254:bat[:oid,:str] =<tmp_7573>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,27,32); | | 34 | X_371:bat[:oid,:str] =<tmpr_7505>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,30,32); | | 21 | X_348:bat[:oid,:str] =<tmpr_7606>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,23,32); | | 539 | X_162:bat[:oid,:str] =<tmpr_7307>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,31,32); | | 49 | X_465:bat[:oid,:str] =<tmp_7556>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,26,32); | | 219 | X_248:bat[:oid,:str] =<tmp_7470>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,25,32); | | 59 | X_546=<tmp_7535>[3206629] := algebra.kdifference(X_268=nil:bat[:oid,:str],X_162=<tmpr_7307>:bat[:oid,:str][0]); | | 406 | X_141:bat[:oid,:str] =<tmpr_7506>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,25,32); | | 362 | X_148:bat[:oid,:str] =<tmpr_7531>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,27,32); | | 179 | X_354:bat[:oid,:str] =<tmpr_7503>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,25,32); | | 531 | X_358:bat[:oid,:str] =<tmpr_7510>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,26,32); | | 491 | X_14:bat[:oid,:str] =<tmp_7013>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",1); | | 202 | X_478:bat[:oid,:str] =<tmp_7317>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,30,32); | | 40 | X_15=<tmp_7521>[0] := algebra.uselect(X_14=nil:bat[:oid,:str],A0="201110"); | | 438 | X_158:bat[:oid,:str] =<tmpr_7443>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,30,32); | | 25 | X_129:bat[:oid,:str] =<tmpr_7535>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,21,32); | | 154 | X_481:bat[:oid,:str] =<tmp_7522>[3206629] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,31,32); | | 44 | X_241:bat[:oid,:str] =<tmp_7566>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,23,32); | | 62 | X_135:bat[:oid,:str] =<tmpr_7435>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,23,32); | | 1094 | X_6:bat[:oid,:str] =<tmp_7326>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",1); | | 331 | X_245:bat[:oid,:str] =<tmp_7477>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,24,32); | | 887 | X_475:bat[:oid,:str] =<tmp_7453>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,29,32); | | 17 | X_351:bat[:oid,:str] =<tmpr_7516>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,24,32); | | 128 | X_265:bat[:oid,:str] =<tmp_7541>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,30,32); | | 13 | X_232:bat[:oid,:str] =<tmp_7477>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,20,32); | | 1075 | X_375:bat[:oid,:str] =<tmpr_7376>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,31,32); | | 966 | X_468:bat[:oid,:str] =<tmp_7564>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,27,32); | | 16 | X_445:bat[:oid,:str] =<tmp_7611>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,20,32); | | 48 | X_458:bat[:oid,:str] =<tmp_7545>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,24,32); | | 59 | X_536=<tmp_7571>[3206628] := algebra.kdifference(X_251=nil:bat[:oid,:str],X_145=<tmpr_7515>:bat[:oid,:str][0]); | | 222 | X_258:bat[:oid,:str] =<tmp_7263>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,28,32); | | 11 | X_454:bat[:oid,:str] =<tmp_7530>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,23,32); | | 22 | X_132:bat[:oid,:str] =<tmpr_7447>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,22,32); | | 259 | X_151:bat[:oid,:str] =<tmpr_7340>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,28,32); | | 20 | X_238:bat[:oid,:str] =<tmp_7546>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,22,32); | | 38 | X_345:bat[:oid,:str] =<tmpr_7047>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,22,32); | | 44 | X_534=<tmp_7467>[3206628] := algebra.kdifference(X_248=nil:bat[:oid,:str],X_141=<tmpr_7506>:bat[:oid,:str][0]); | | 43 | X_538=<tmp_7470>[3206628] := algebra.kdifference(X_254=nil:bat[:oid,:str],X_148=<tmpr_7531>:bat[:oid,:str][0]); | | 47 | X_611=<tmp_7573>[3206629] := algebra.kunion(X_546=nil,X_162=nil:bat[:oid,:str]); | | 11 | X_451:bat[:oid,:str] =<tmp_7307>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,22,32); | | 33 | X_599=<tmp_7464>[3206628] := algebra.kunion(X_534=nil,X_141=nil:bat[:oid,:str]); | | 34 | X_603=<tmp_7506>[3206628] := algebra.kunion(X_538=nil,X_148=nil:bat[:oid,:str]); | | 59 | X_235:bat[:oid,:str] =<tmp_7562>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,21,32); | | 19 | X_225:bat[:oid,:str] =<tmp_7470>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,18,32); | | 23 | X_526=<tmp_7467>[3206628] := algebra.kdifference(X_235=nil:bat[:oid,:str],X_129=<tmpr_7535>:bat[:oid,:str][0]); | | 14 | X_332:bat[:oid,:str] =<tmpr_7562>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,18,32); | | 13 | X_438:bat[:oid,:str] =<tmp_7532>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,18,32); | | 10 | X_115:bat[:oid,:str] =<tmpr_7547>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,17,32); | | 7 | X_221:bat[:oid,:str] =<tmp_7466>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,17,32); | | 8 | X_329:bat[:oid,:str] =<tmpr_7472>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,17,32); | | 5 | X_435:bat[:oid,:str] =<tmp_7604>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,17,32); | | 37 | X_530=<tmp_7465>[3206628] := algebra.kdifference(X_241=nil:bat[:oid,:str],X_135=<tmpr_7435>:bat[:oid,:str][0]); | | 32 | X_125:bat[:oid,:str] =<tmpr_7566>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,20,32); | | 88 | X_532=<tmp_7554>[3206628] := algebra.kdifference(X_245=nil:bat[:oid,:str],X_138=<tmpr_7555>:bat[:oid,:str][0]); | | 235 | X_362:bat[:oid,:str] =<tmpr_7540>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,27,32); | | 18 | X_338:bat[:oid,:str] =<tmpr_7541>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,20,32); | | 42 | X_544=<tmp_7544>[3206628] := algebra.kdifference(X_265=nil:bat[:oid,:str],X_158=<tmpr_7443>:bat[:oid,:str][0]); | | 43 | X_597=<tmp_7435>[3206628] := algebra.kunion(X_532=nil,X_138=nil:bat[:oid,:str]); | | 23 | X_121:bat[:oid,:str] =<tmpr_7476>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,19,32); | | 88 | X_518=<tmp_7555>[3206628] := algebra.kdifference(X_221=nil:bat[:oid,:str],X_115=<tmpr_7547>:bat[:oid,:str][0]); | | 18 | X_609=<tmp_7466>[3206628] := algebra.kunion(X_544=nil,X_158=nil:bat[:oid,:str]); | | 37 | X_540=<tmp_7571>[3206628] := algebra.kdifference(X_258=nil:bat[:oid,:str],X_151=<tmpr_7340>:bat[:oid,:str][0]); | | 27 | X_528=<tmp_7263>[3206628] := algebra.kdifference(X_238=nil:bat[:oid,:str],X_132=<tmpr_7447>:bat[:oid,:str][0]); | | 20 | X_432:bat[:oid,:str] =<tmp_7547>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,16,32); | | 29 | X_442:bat[:oid,:str] =<tmp_7607>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,19,32); | | 30 | X_605=<tmp_7555>[3206628] := algebra.kunion(X_540=nil,X_151=nil:bat[:oid,:str]); | | 733 | X_365:bat[:oid,:str] =<tmpr_7536>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,28,32); | | 18 | X_118:bat[:oid,:str] =<tmpr_7531>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,18,32); | | 12 | X_342:bat[:oid,:str] =<tmpr_7523>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,21,32); | | 19 | X_448:bat[:oid,:str] =<tmp_7475>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,21,32); | | 36 | X_591=<tmp_7567>[3206628] := algebra.kunion(X_526=nil,X_129=nil:bat[:oid,:str]); | | 36 | X_524=<tmp_7535>[3206628] := algebra.kdifference(X_232=nil:bat[:oid,:str],X_125=<tmpr_7566>:bat[:oid,:str][0]); | | 39 | X_595=<tmp_7477>[3206628] := algebra.kunion(X_530=nil,X_135=nil:bat[:oid,:str]); | | 18 | X_429:bat[:oid,:str] =<tmp_7467>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,15,32); | | 20 | X_112:bat[:oid,:str] =<tmpr_7554>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,16,32); | | 42 | X_601=<tmp_7445>[3206628] := algebra.kunion(X_536=nil,X_145=nil:bat[:oid,:str]); | | 15 | X_229:bat[:oid,:str] =<tmp_7515>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,19,32); | | 20 | X_218:bat[:oid,:str] =<tmp_7443>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,16,32); | | 44 | X_325:bat[:oid,:str] =<tmpr_7544>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,16,32); | | 41 | X_522=<tmp_7535>[3206628] := algebra.kdifference(X_229=nil:bat[:oid,:str],X_121=<tmpr_7476>:bat[:oid,:str][0]); | | 38 | X_516=<tmp_7515>[3206628] := algebra.kdifference(X_218=nil:bat[:oid,:str],X_112=<tmpr_7554>:bat[:oid,:str][0]); | | 14 | X_425:bat[:oid,:str] =<tmp_7500>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,14,32); | | 19 | X_587=<tmp_7537>[3206628] := algebra.kunion(X_522=nil,X_121=nil:bat[:oid,:str]); | | 12 | X_581=<tmp_7476>[3206628] := algebra.kunion(X_516=nil,X_112=nil:bat[:oid,:str]); | | 16 | X_102:bat[:oid,:str] =<tmpr_7554>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,13,32); | | 6 | X_208:bat[:oid,:str] =<tmp_7515>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,13,32); | | 8 | X_510=<tmp_7535>[3206628] := algebra.kdifference(X_208=nil:bat[:oid,:str],X_102=<tmpr_7554>:bat[:oid,:str][0]); | | 13 | X_315:bat[:oid,:str] =<tmpr_7515>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,13,32); | | 9 | X_575=<tmp_7563>[3206628] := algebra.kunion(X_510=nil,X_102=nil:bat[:oid,:str]); | | 6 | X_421:bat[:oid,:str] =<tmp_7554>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,13,32); | | 10766 | X_679=<tmp_7062>[0] := algebra.uselect(X_378=nil:bat[:oid,:str],A0="201110"); | | 207 | X_262:bat[:oid,:str] =<tmp_7512>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,29,32); | | 16 | X_593=<tmp_7571>[3206628] := algebra.kunion(X_528=nil,X_132=nil:bat[:oid,:str]); | | 29 | X_108:bat[:oid,:str] =<tmpr_7340>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,15,32); | | 19 | X_205:bat[:oid,:str] =<tmp_7512>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,12,32); | | 17 | X_215:bat[:oid,:str] =<tmp_7470>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,15,32); | | 40 | X_321:bat[:oid,:str] =<tmpr_7263>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,15,32); | | 44 | X_312:bat[:oid,:str] =<tmpr_7534>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,12,32); | | 42 | X_589=<tmp_7502>[3206628] := algebra.kunion(X_524=nil,X_125=nil:bat[:oid,:str]); | | 13 | X_202:bat[:oid,:str] =<tmp_7433>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,11,32); | | 18 | X_212:bat[:oid,:str] =<tmp_7566>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,14,32); | | 38 | X_583=<tmp_7465>[3206628] := algebra.kunion(X_518=nil,X_115=nil:bat[:oid,:str]); | | 10 | X_415:bat[:oid,:str] =<tmp_7525>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,11,32); | | 48 | X_335:bat[:oid,:str] =<tmpr_7546>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,19,32); | | 23 | X_99:bat[:oid,:str] =<tmpr_7316>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,12,32); | | 33 | X_542=<tmp_7526>[3206628] := algebra.kdifference(X_262=nil:bat[:oid,:str],X_154=<tmpr_7524>:bat[:oid,:str][0]); | | 33 | X_520=<tmp_7447>[3206628] := algebra.kdifference(X_225=nil:bat[:oid,:str],X_118=<tmpr_7531>:bat[:oid,:str][0]); | | 33 | X_508=<tmp_7614>[3206628] := algebra.kdifference(X_205=nil:bat[:oid,:str],X_99=<tmpr_7316>:bat[:oid,:str][0]); | | 26 | X_412:bat[:oid,:str] =<tmp_7605>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,10,32); | | 32 | X_514=<tmp_7560>[3206628] := algebra.kdifference(X_215=nil:bat[:oid,:str],X_108=<tmpr_7340>:bat[:oid,:str][0]); | | 29 | X_96:bat[:oid,:str] =<tmpr_7470>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,11,32); | | 13 | X_105:bat[:oid,:str] =<tmpr_7517>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,14,32); | | 26 | X_573=<tmp_7447>[3206628] := algebra.kunion(X_508=nil,X_99=nil:bat[:oid,:str]); | | 35 | X_506=<tmp_7316>[3206628] := algebra.kdifference(X_202=nil:bat[:oid,:str],X_96=<tmpr_7470>:bat[:oid,:str][0]); | | 35 | X_512=<tmp_7433>[3206628] := algebra.kdifference(X_212=nil:bat[:oid,:str],X_105=<tmpr_7517>:bat[:oid,:str][0]); | | 22 | X_92:bat[:oid,:str] =<tmpr_7172>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,10,32); | | 27 | X_302:bat[:oid,:str] =<tmpr_7526>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,9,32); | | 38 | X_199:bat[:oid,:str] =<tmp_7600>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,10,32); | | 10696 | X_730=<tmp_7346>[0] := algebra.uselect(X_462=nil:bat[:oid,:str],A0="201110"); | | 18 | X_418:bat[:oid,:str] =<tmp_7552>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,12,32); | | 70 | X_305:bat[:oid,:str] =<tmpr_7512>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,10,32); | | 724 | X_471:bat[:oid,:str] =<tmp_7511>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,28,32); | | 47 | X_607=<tmp_7551>[3206628] := algebra.kunion(X_542=nil,X_154=nil:bat[:oid,:str]); | | 31 | X_585=<tmp_7524>[3206628] := algebra.kunion(X_520=nil,X_118=nil:bat[:oid,:str]); | | 30 | X_88:bat[:oid,:str] =<tmpr_7566>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,9,32); | | 66 | X_409:bat[:oid,:str] =<tmp_7560>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,9,32); | | 37 | X_196:bat[:oid,:str] =<tmp_7614>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,9,32); | | 42 | X_85:bat[:oid,:str] =<tmpr_7340>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,8,32); | | 13 | X_318:bat[:oid,:str] =<tmpr_7443>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,14,32); | | 31 | X_571=<tmp_7517>[3206628] := algebra.kunion(X_506=nil,X_96=nil:bat[:oid,:str]); | | 15 | X_405:bat[:oid,:str] =<tmp_7570>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,8,32); | | 14 | X_504=<tmp_7470>[3206628] := algebra.kdifference(X_199=nil:bat[:oid,:str],X_92=<tmpr_7172>:bat[:oid,:str][0]); | | 27 | X_795=<tmp_7600>[0] := algebra.kdifference(X_730=nil,X_354=<tmpr_7503>:bat[:oid,:str][0]); | | 11 | X_188:bat[:oid,:str] =<tmp_7543>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,7,32); | | 47 | X_309:bat[:oid,:str] =<tmpr_7520>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,11,32); | | 20 | X_192:bat[:oid,:str] =<tmp_7577>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,8,32); | | 25 | X_577=<tmp_7533>[3206628] := algebra.kunion(X_512=nil,X_105=nil:bat[:oid,:str]); | | 10936 | X_740=<tmp_7320>[0] := algebra.uselect(X_478=nil:bat[:oid,:str],A0="201110"); | | 133 | X_500=<tmp_7172>[3206628] := algebra.kdifference(X_192=nil:bat[:oid,:str],X_85=<tmpr_7340>:bat[:oid,:str][0]); | | 22 | X_299:bat[:oid,:str] =<tmpr_7614>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,8,32); | | 37 | X_82:bat[:oid,:str] =<tmpr_7174>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,7,32); | | 108 | X_579=<tmp_7433>[3206628] := algebra.kunion(X_514=nil,X_108=nil:bat[:oid,:str]); | | 11122 | X_742=<tmp_7373>[0] := algebra.uselect(X_481=nil:bat[:oid,:str],A0="201110"); | | 47 | X_665=<tmp_7513>[0] := algebra.uselect(X_354=nil:bat[:oid,:str],A0="201110"); | | 32 | X_569=<tmp_7603>[3206628] := algebra.kunion(X_504=nil,X_92=nil:bat[:oid,:str]); | | 51 | X_296:bat[:oid,:str] =<tmpr_7503>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,7,32); | | 10966 | X_738=<tmp_7071>[0] := algebra.uselect(X_475=nil:bat[:oid,:str],A0="201110"); | | 14 | X_402:bat[:oid,:str] =<tmp_7453>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,7,32); | | 26 | X_502=<tmp_7550>[3206628] := algebra.kdifference(X_196=nil:bat[:oid,:str],X_88=<tmpr_7566>:bat[:oid,:str][0]); | | 22 | X_805=<tmp_7577>[0] := algebra.kdifference(X_740=nil,X_371=<tmpr_7505>:bat[:oid,:str][0]); | | 13 | X_79:bat[:oid,:str] =<tmpr_7470>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,6,32); | | 36 | X_565=<tmp_7522>[3206628] := algebra.kunion(X_500=nil,X_85=nil:bat[:oid,:str]); | | 110 | X_675=<tmp_7504>[0] := algebra.uselect(X_371=nil:bat[:oid,:str],A0="201110"); | | 10868 | X_728=<tmp_7210>[0] := algebra.uselect(X_458=nil:bat[:oid,:str],A0="201110"); | | 73 | X_567=<tmp_7505>[3206628] := algebra.kunion(X_502=nil,X_88=nil:bat[:oid,:str]); | | 43 | X_185:bat[:oid,:str] =<tmp_7611>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,6,32); | | 11240 | X_734=<tmp_7156>[0] := algebra.uselect(X_468=nil:bat[:oid,:str],A0="201110"); | | 74 | X_870=<tmp_7566>[0] := algebra.kunion(X_805=nil,X_675=nil); | | 52 | X_793=<tmp_7577>[0] := algebra.kdifference(X_728=nil,X_351=<tmpr_7516>:bat[:oid,:str][0]); | | 43 | X_807=<tmp_7513>[0] := algebra.kdifference(X_742=nil,X_375=<tmpr_7376>:bat[:oid,:str][0]); | | 67 | X_396:bat[:oid,:str] =<tmp_7307>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,5,32); | | 44 | X_803=<tmp_7543>[0] := algebra.kdifference(X_738=nil,X_368=<tmpr_7471>:bat[:oid,:str][0]); | | 63 | X_75:bat[:oid,:str] =<tmpr_7575>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,5,32); | | 11330 | X_726=<tmp_7313>[0] := algebra.uselect(X_454=nil:bat[:oid,:str],A0="201110"); | | 11092 | X_716=<tmp_7237>[0] := algebra.uselect(X_438=nil:bat[:oid,:str],A0="201110"); | | 23 | X_182:bat[:oid,:str] =<tmp_7530>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,5,32); | | 11054 | X_720=<tmp_7074>[0] := algebra.uselect(X_445=nil:bat[:oid,:str],A0="201110"); | | 32 | X_860=<tmp_7564>[0] := algebra.kunion(X_795=nil,X_665=nil); | | 63 | X_288:bat[:oid,:str] =<tmpr_7504>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,5,32); | | 33 | X_292:bat[:oid,:str] =<tmpr_7600>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,6,32); | | 16 | X_799=<tmp_7550>[0] := algebra.kdifference(X_734=nil,X_362=<tmpr_7540>:bat[:oid,:str][0]); | | 62 | X_496=<tmp_7542>[3206628] := algebra.kdifference(X_185=nil:bat[:oid,:str],X_79=<tmpr_7470>:bat[:oid,:str][0]); | | 28 | X_669=<tmp_7436>[0] := algebra.uselect(X_362=nil:bat[:oid,:str],A0="201110"); | | 15 | X_399:bat[:oid,:str] =<tmp_7545>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,6,32); | | 51 | X_69:bat[:oid,:str] =<tmpr_7436>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,3,32); | | 67 | X_677=<tmp_7611>[0] := algebra.uselect(X_375=nil:bat[:oid,:str],A0="201110"); | | 44 | X_673=<tmp_7516>[0] := algebra.uselect(X_368=nil:bat[:oid,:str],A0="201110"); | | 14 | X_72:bat[:oid,:str] =<tmpr_7532>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,4,32); | | 22 | X_498=<tmp_7340>[3206628] := algebra.kdifference(X_188=nil:bat[:oid,:str],X_82=<tmpr_7174>:bat[:oid,:str][0]); | | 14 | X_175:bat[:oid,:str] =<tmp_7516>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,3,32); | | 11062 | X_714=<tmp_7132>[0] := algebra.uselect(X_435=nil:bat[:oid,:str],A0="201110"); | | 23 | X_282:bat[:oid,:str] =<tmpr_7556>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,3,32); | | 30 | X_494=<tmp_7557>[3206628] := algebra.kdifference(X_182=nil:bat[:oid,:str],X_75=<tmpr_7575>:bat[:oid,:str][0]); | | 21 | X_563=<tmp_7513>[3206628] := algebra.kunion(X_498=nil,X_82=nil:bat[:oid,:str]); | | 22 | X_179:bat[:oid,:str] =<tmp_7376>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,4,32); | | 23 | X_285:bat[:oid,:str] =<tmpr_7527>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,4,32); | | 18 | X_392:bat[:oid,:str] =<tmp_7602>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,4,32); | | 11105 | X_724=<tmp_7246>[0] := algebra.uselect(X_451=nil:bat[:oid,:str],A0="201110"); | | 14 | X_864=<tmp_7540>[0] := algebra.kunion(X_799=nil,X_669=nil); | | 57 | X_663=<tmp_7507>[0] := algebra.uselect(X_351=nil:bat[:oid,:str],A0="201110"); | | 14 | X_172:bat[:oid,:str] =<tmp_7542>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,2,32); | | 45 | X_872=<tmp_7470>[0] := algebra.kunion(X_807=nil,X_677=nil); | | 27 | X_868=<tmp_7611>[0] := algebra.kunion(X_803=nil,X_673=nil); | | 27 | X_791=<tmp_7471>[0] := algebra.kdifference(X_726=nil,X_348=<tmpr_7606>:bat[:oid,:str][0]); | | 15235 | X_732=<tmp_7113>[0] := algebra.uselect(X_465=nil:bat[:oid,:str],A0="201110"); | | 22 | X_781=<tmp_7604>[0] := algebra.kdifference(X_716=nil,X_332=<tmpr_7562>:bat[:oid,:str][0]); | | 23 | X_490=<tmp_7543>[3206628] := algebra.kdifference(X_175=nil:bat[:oid,:str],X_69=<tmpr_7436>:bat[:oid,:str][0]); | | 20 | X_779=<tmp_7516>[0] := algebra.kdifference(X_714=nil,X_329=<tmpr_7472>:bat[:oid,:str][0]); | | 14 | X_169:bat[:oid,:str] =<tmp_7612>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,1,32); | | 19 | X_388:bat[:oid,:str] =<tmp_7174>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,3,32); | | 18 | X_276:bat[:oid,:str] =<tmpr_7472>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,1,32); | | 26 | X_492=<tmp_7575>[3206628] := algebra.kdifference(X_179=nil:bat[:oid,:str],X_72=<tmpr_7532>:bat[:oid,:str][0]); | | 23 | X_66:bat[:oid,:str] =<tmpr_7376>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,2,32); | | 20 | X_789=<tmp_7557>[0] := algebra.kdifference(X_724=nil,X_345=<tmpr_7047>:bat[:oid,:str][0]); | | 49 | X_561=<tmp_7242>[3206628] := algebra.kunion(X_496=nil,X_79=nil:bat[:oid,:str]); | | 24 | X_858=<tmp_7550>[0] := algebra.kunion(X_793=nil,X_663=nil); | | 11198 | X_712=<tmp_7203>[0] := algebra.uselect(X_432=nil:bat[:oid,:str],A0="201110"); | | 39 | X_385:bat[:oid,:str] =<tmp_7577>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,2,32); | | 37 | X_63:bat[:oid,:str] =<tmpr_7501>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,1,32); | | 52 | X_661=<tmp_7576>[0] := algebra.uselect(X_348=nil:bat[:oid,:str],A0="201110"); | | 35 | X_797=<tmp_7606>[0] := algebra.kdifference(X_732=nil,X_358=<tmpr_7510>:bat[:oid,:str][0]); | | 22 | X_785=<tmp_7530>[0] := algebra.kdifference(X_720=nil,X_338=<tmpr_7541>:bat[:oid,:str][0]); | | 40 | X_651=<tmp_7613>[0] := algebra.uselect(X_332=nil:bat[:oid,:str],A0="201110"); | | 31 | X_649=<tmp_7574>[0] := algebra.uselect(X_329=nil:bat[:oid,:str],A0="201110"); | | 33 | X_655=<tmp_7576>[0] := algebra.uselect(X_338=nil:bat[:oid,:str],A0="201110"); | | 26 | X_382:bat[:oid,:str] =<tmp_7615>[3206628] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0,1,32); | | 36 | X_844=<tmp_7613>[0] := algebra.kunion(X_779=nil,X_649=nil); | | 42 | X_488=<tmp_7616>[3206628] := algebra.kdifference(X_172=nil:bat[:oid,:str],X_66=<tmpr_7376>:bat[:oid,:str][0]); | | 108 | X_659=<tmp_7617>[0] := algebra.uselect(X_345=nil:bat[:oid,:str],A0="201110"); | | 49 | X_557=<tmp_7547>[3206628] := algebra.kunion(X_492=nil,X_72=nil:bat[:oid,:str]); | | 11451 | X_710=<tmp_7144>[0] := algebra.uselect(X_429=nil:bat[:oid,:str],A0="201110"); | | 11278 | X_718=<tmp_7077>[0] := algebra.uselect(X_442=nil:bat[:oid,:str],A0="201110"); | | 24 | X_777=<tmp_7607>[0] := algebra.kdifference(X_712=nil,X_325=<tmpr_7544>:bat[:oid,:str][0]); | | 30 | X_486=<tmp_7436>[3206628] := algebra.kdifference(X_169=nil:bat[:oid,:str],X_63=<tmpr_7501>:bat[:oid,:str][0]); | | 50 | X_856=<tmp_7612>[0] := algebra.kunion(X_791=nil,X_661=nil); | | 63 | X_667=<tmp_7471>[0] := algebra.uselect(X_358=nil:bat[:oid,:str],A0="201110"); | | 25 | X_559=<tmp_7340>[3206628] := algebra.kunion(X_494=nil,X_75=nil:bat[:oid,:str]); | | 32 | X_846=<tmp_7541>[0] := algebra.kunion(X_781=nil,X_651=nil); | | 23 | X_59:bat[:oid,:str] =<tmpr_7562>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2,0,32); | | 19 | X_850=<tmp_7574>[0] := algebra.kunion(X_785=nil,X_655=nil); | | 27 | X_165:bat[:oid,:str] =<tmp_7576>[3206628] := sql.bind(X_3=0,"sys","f_sorted","uuid",0,0,32); | | 11583 | X_722=<tmp_7223>[0] := algebra.uselect(X_448=nil:bat[:oid,:str],A0="201110"); | | 10 | X_12:bat[:oid,:oid] =<tmp_7003>[0] := sql.bind_dbat(X_3=0,"sys","f_sorted",1); | | 30 | X_555=<tmp_7532>[3206628] := algebra.kunion(X_490=nil,X_69=nil:bat[:oid,:str]); | | 29 | X_787=<tmp_7576>[0] := algebra.kdifference(X_722=nil,X_342=<tmpr_7523>:bat[:oid,:str][0]); | | 46 | X_553=<tmp_7617>[3206628] := algebra.kunion(X_488=nil,X_66=nil:bat[:oid,:str]); | | 11209 | X_708=<tmp_7133>[0] := algebra.uselect(X_425=nil:bat[:oid,:str],A0="201110"); | | 29 | X_775=<tmp_7500>[0] := algebra.kdifference(X_710=nil,X_321=<tmpr_7263>:bat[:oid,:str][0]); | | 26 | X_279:bat[:oid,:str] =<tmpr_7507>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,2,32); | | 28 | X_783=<tmp_7376>[0] := algebra.kdifference(X_718=nil,X_335=<tmpr_7546>:bat[:oid,:str][0]); | | 32 | X_647=<tmp_7557>[0] := algebra.uselect(X_325=nil:bat[:oid,:str],A0="201110"); | | 23 | X_271:bat[:oid,:str] =<tmpr_7544>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2,0,32); | | 51 | X_551=<tmp_7616>[3206628] := algebra.kunion(X_486=nil,X_63=nil:bat[:oid,:str]); | | 42 | X_862=<tmp_7501>[0] := algebra.kunion(X_797=nil,X_667=nil); | | 24 | X_483=<tmp_7471>[3206628] := algebra.kdifference(X_165=nil:bat[:oid,:str],X_59=<tmpr_7562>:bat[:oid,:str][0]); | | 11 | X_13=<tmpr_7003>[0] := bat.reverse(X_12=nil:bat[:oid,:oid]); | | 25 | X_854=<tmp_7467>[0] := algebra.kunion(X_789=nil,X_659=nil); | | 32 | X_909=<tmp_7546>[0] := algebra.kdifference(X_844=nil,X_13=<tmpr_7003>[0]); | | 119 | X_548=<tmp_7607>[3206628] := algebra.kunion(X_483=nil,X_59=nil:bat[:oid,:str]); | | 13 | X_1013=<tmp_7562>[0] := algebra.markT(X_909=nil,33,17); | | 39 | X_645=<tmp_7475>[0] := algebra.uselect(X_321=nil:bat[:oid,:str],A0="201110"); | | 114 | X_927=<tmp_7546>[0] := algebra.kdifference(X_862=nil,X_13=<tmpr_7003>[0]); | | 22 | X_842=<tmp_7263>[0] := algebra.kunion(X_777=nil,X_647=nil); | | 154 | X_929=<tmp_7471>[0] := algebra.kdifference(X_864=nil,X_13=<tmpr_7003>[0]); | | 93 | X_921=<tmp_7540>[0] := algebra.kdifference(X_856=nil,X_13=<tmpr_7003>[0]); | | 25 | X_773=<tmp_7523>[0] := algebra.kdifference(X_708=nil,X_318=<tmpr_7443>:bat[:oid,:str][0]); | | 375 | X_937=<tmp_7500>[0] := algebra.kdifference(X_872=nil,X_13=<tmpr_7003>[0]); | | 401 | X_925=<tmp_7574>[0] := algebra.kdifference(X_860=nil,X_13=<tmpr_7003>[0]); | | 25 | X_643=<tmp_7471>[0] := algebra.uselect(X_318=nil:bat[:oid,:str],A0="201110"); | | 14 | X_1070=<tmp_7443>[0] := algebra.markT(X_937=nil,33,31); | | 19 | X_744=<tmp_7557>[0] := algebra.kdifference(X_679=nil,X_271=<tmpr_7544>:bat[:oid,:str][0]); | | 4 | X_1173=<tmpr_7443>[0] := bat.reverse(X_1070=nil); | | 41 | X_657=<tmp_7436>[0] := algebra.uselect(X_342=nil:bat[:oid,:str],A0="201110"); | | 36 | X_615=<tmp_7523>[0] := algebra.uselect(X_271=nil:bat[:oid,:str],A0="201110"); | | 36 | X_1050=<tmp_7475>[0] := algebra.markT(X_927=nil,33,26); | | 26 | X_852=<tmp_7573>[0] := algebra.kunion(X_787=nil,X_657=nil); | | 5 | X_1158=<tmpr_7475>[0] := bat.reverse(X_1050=nil); | | 161 | X_915=<tmp_7612>[0] := algebra.kdifference(X_850=nil,X_13=<tmpr_7003>[0]); | | 3 | X_1131=<tmpr_7562>[0] := bat.reverse(X_1013=nil); | | 71 | X_1054=<tmp_7470>[0] := algebra.markT(X_929=nil,33,27); | | 59 | X_1025=<tmp_7445>[0] := algebra.markT(X_915=nil,33,20); | | 40 | X_1214=<tmp_7104>[0] := algebra.leftjoin(X_1131=nil,X_583=nil); | | 48 | X_653=<tmp_7606>[0] := algebra.uselect(X_335=nil:bat[:oid,:str],A0="201110"); | | 105 | X_919=<tmp_7501>[0] := algebra.kdifference(X_854=nil,X_13=<tmpr_7003>[0]); | | 94 | X_933=<tmp_7467>[0] := algebra.kdifference(X_868=nil,X_13=<tmpr_7003>[0]); | | 29 | X_848=<tmp_7465>[0] := algebra.kunion(X_783=nil,X_653=nil); | | 16 | X_838=<tmp_7574>[0] := algebra.kunion(X_773=nil,X_643=nil); | | 62 | X_935=<tmp_7611>[0] := algebra.kdifference(X_870=nil,X_13=<tmpr_7003>[0]); | | 80 | X_840=<tmp_7613>[0] := algebra.kunion(X_775=nil,X_645=nil); | | 14 | X_1066=<tmp_7574>[0] := algebra.markT(X_935=nil,33,30); | | 105 | X_923=<tmp_7546>[0] := algebra.kdifference(X_858=nil,X_13=<tmpr_7003>[0]); | | 27 | X_905=<tmp_7611>[0] := algebra.kdifference(X_840=nil,X_13=<tmpr_7003>[0]); | | 46 | X_907=<tmp_7566>[0] := algebra.kdifference(X_842=nil,X_13=<tmpr_7003>[0]); | | 19 | X_1041=<tmp_7613>[0] := algebra.markT(X_923=nil,33,24); | | 63 | X_1232=<tmp_7131>[0] := algebra.leftjoin(X_1158=nil,X_601=nil); | | 27 | X_1008=<tmp_7611>[0] := algebra.markT(X_907=nil,33,16); | | 17 | X_1037=<tmp_7541>[0] := algebra.markT(X_921=nil,33,23); | | 3 | X_1140=<tmpr_7445>[0] := bat.reverse(X_1025=nil); | | 10 | X_1161=<tmpr_7470>[0] := bat.reverse(X_1054=nil); | | 31 | (X_1298=<tmp_7553>[0],X_1299) := group.done(X_1214=<tmp_7104>[0]); | | 18 | X_1046=<tmp_7500>[0] := algebra.markT(X_925=nil,33,25); | | 49 | X_1234=<tmp_7004>[0] := algebra.leftjoin(X_1161=nil,X_603=nil); | | 11 | X_1398=<tmp_7566>[0] := bat.mirror(X_1298=nil); | | 72 | X_1033=<tmp_7467>[0] := algebra.markT(X_919=nil,33,22); | | 26 | (X_1328=<tmp_7553>[0],X_1329) := group.done(X_1234=<tmp_7004>[0]); | | 31 | X_1242=<tmp_7370>[0] := algebra.leftjoin(X_1173=nil,X_611=nil); | | 4 | X_1170=<tmpr_7574>[0] := bat.reverse(X_1066=nil); | | 19 | X_809=<tmp_7436>[0] := algebra.kunion(X_744=nil,X_615=nil); | | 17 | X_1004=<tmp_7546>[0] := algebra.markT(X_905=nil,33,15); | | 10 | X_917=<tmp_7523>[0] := algebra.kdifference(X_852=nil,X_13=<tmpr_7003>[0]); | | 6 | X_1125=<tmpr_7546>[0] := bat.reverse(X_1004=nil); | | 41 | X_911=<tmp_7263>[0] := algebra.kdifference(X_846=nil,X_13=<tmpr_7003>[0]); | | 26 | (X_1325=<tmp_7572>[0],X_1326) := group.done(X_1232=<tmp_7131>[0]); | | 4 | X_1128=<tmpr_7611>[0] := bat.reverse(X_1008=nil); | | 64 | X_1210=<tmp_7221>[0] := algebra.leftjoin(X_1125=nil,X_579=nil); | | 34 | X_1220=<tmp_7327>[0] := algebra.leftjoin(X_1140=nil,X_589=nil); | | 35 | X_1212=<tmp_7342>[0] := algebra.leftjoin(X_1128=nil,X_581=nil); | | 17 | X_913=<tmp_7376>[0] := algebra.kdifference(X_848=nil,X_13=<tmpr_7003>[0]); | | 9 | X_1155=<tmpr_7500>[0] := bat.reverse(X_1046=nil); | | 10 | X_1021=<tmp_7476>[0] := algebra.markT(X_913=nil,33,19); | | 21 | X_1400=<tmp_7367>[0] := algebra.leftjoin(X_1398=nil,X_1214=<tmp_7104>[0]); | | 5 | X_1137=<tmpr_7476>[0] := bat.reverse(X_1021=nil); | | 5 | X_1428=<tmp_7566>[0] := bat.mirror(X_1328=nil); | | 28 | (X_1340=<tmp_7553>[0],X_1341) := group.done(X_1242=<tmp_7370>[0]); | | 14 | X_1430=<tmp_7075>[0] := algebra.leftjoin(X_1428=nil,X_1234=<tmp_7004>[0]); | | 22 | X_874=<tmp_7506>[0] := algebra.kdifference(X_809=nil,X_13=<tmpr_7003>[0]); | | 4 | X_1152=<tmpr_7613>[0] := bat.reverse(X_1041=nil); | | 36 | X_1029=<tmp_7436>[0] := algebra.markT(X_917=nil,33,21); | | 14 | X_1017=<tmp_7523>[0] := algebra.markT(X_911=nil,33,18); | | 17 | X_1425=<tmp_7433>[0] := bat.mirror(X_1325=nil); | | 8 | X_1134=<tmpr_7523>[0] := bat.reverse(X_1017=nil); | | 18 | X_1062=<tmp_7606>[0] := algebra.markT(X_933=nil,33,29); | | 31 | (X_1292=<tmp_7572>[0],X_1293) := group.done(X_1210=<tmp_7221>[0]); | | 10 | X_1167=<tmpr_7606>[0] := bat.reverse(X_1062=nil); | | 11618 | X_736=<tmp_7304>[0] := algebra.uselect(X_471=nil:bat[:oid,:str],A0="201110"); | | 27 | X_1238=<tmp_6767>[0] := algebra.leftjoin(X_1167=nil,X_607=nil); | | 15 | X_903=<tmp_7501>[0] := algebra.kdifference(X_838=nil,X_13=<tmpr_7003>[0]); | | 5 | X_1146=<tmpr_7467>[0] := bat.reverse(X_1033=nil); | | 28 | X_801=<tmp_7606>[0] := algebra.kdifference(X_736=nil,X_365=<tmpr_7536>:bat[:oid,:str][0]); | | 31 | X_1218=<tmp_7254>[0] := algebra.leftjoin(X_1137=nil,X_587=nil); | | 34 | X_1240=<tmp_7245>[0] := algebra.leftjoin(X_1170=nil,X_609=nil); | | 42 | X_671=<tmp_7467>[0] := algebra.uselect(X_365=nil:bat[:oid,:str],A0="201110"); | | 24 | X_941=<tmp_7537>[0] := algebra.markT(X_874=nil,33,0); | | 33 | X_1228=<tmp_7145>[0] := algebra.leftjoin(X_1152=nil,X_597=nil); | | 6 | X_1143=<tmpr_7436>[0] := bat.reverse(X_1029=nil); | | 26 | (X_1319=<tmp_7474>[0],X_1320) := group.done(X_1228=<tmp_7145>[0]); | | 19 | X_1427=<tmp_7311>[0] := algebra.leftjoin(X_1425=nil,X_1232=<tmp_7131>[0]); | | 23 | X_1216=<tmp_7233>[0] := algebra.leftjoin(X_1134=nil,X_585=nil); | | 23 | (X_1307=<tmp_7425>[0],X_1308) := group.done(X_1220=<tmp_7327>[0]); | | 15 | X_1392=<tmp_7433>[0] := bat.mirror(X_1292=nil); | | 25 | (X_1295=<tmp_7601>[0],X_1296) := group.done(X_1212=<tmp_7342>[0]); | | 52 | (X_1334=<tmp_7572>[0],X_1335) := group.done(X_1238=<tmp_6767>[0]); | | 51 | X_1230=<tmp_7117>[0] := algebra.leftjoin(X_1155=nil,X_599=nil); | | 25 | X_1000=<tmp_7551>[0] := algebra.markT(X_903=nil,33,14); | | 36 | X_1224=<tmp_7140>[0] := algebra.leftjoin(X_1146=nil,X_593=nil); | | 3 | X_1122=<tmpr_7551>[0] := bat.reverse(X_1000=nil); | | 37 | (X_1322=<tmp_7572>[0],X_1323) := group.done(X_1230=<tmp_7117>[0]); | | 11205 | X_690=<tmp_7320>[0] := algebra.uselect(X_396=nil:bat[:oid,:str],A0="201110"); | | 24 | X_866=<tmp_7536>[0] := algebra.kunion(X_801=nil,X_671=nil); | | 17 | X_755=<tmp_7533>[0] := algebra.kdifference(X_690=nil,X_288=<tmpr_7504>:bat[:oid,:str][0]); | | 7 | X_1149=<tmpr_7541>[0] := bat.reverse(X_1037=nil); | | 31 | X_931=<tmp_7551>[0] := algebra.kdifference(X_866=nil,X_13=<tmpr_7003>[0]); | | 51 | X_1222=<tmp_7056>[0] := algebra.leftjoin(X_1143=nil,X_591=nil); | | 16 | X_1058=<tmp_7504>[0] := algebra.markT(X_931=nil,33,28); | | 12 | X_1407=<tmp_7567>[0] := bat.mirror(X_1307=nil); | | 26 | X_1394=<tmp_7336>[0] := algebra.leftjoin(X_1392=nil,X_1210=<tmp_7221>[0]); | | 13 | X_1409=<tmp_7110>[0] := algebra.leftjoin(X_1407=nil,X_1220=<tmp_7327>[0]); | | 14 | X_1434=<tmp_7436>[0] := bat.mirror(X_1334=nil); | | 12 | X_1440=<tmp_7566>[0] := bat.mirror(X_1340=nil); | | 25 | (X_1304=<tmp_7553>[0],X_1305) := group.done(X_1218=<tmp_7254>[0]); | | 24 | X_1442=<tmp_7124>[0] := algebra.leftjoin(X_1440=nil,X_1242=<tmp_7370>[0]); | | 21 | X_1208=<tmp_7202>[0] := algebra.leftjoin(X_1122=nil,X_577=nil); | | 54 | (X_1313=<tmp_7601>[0],X_1314) := group.done(X_1224=<tmp_7140>[0]); | | 19 | (X_1289=<tmp_7553>[0],X_1290) := group.done(X_1208=<tmp_7202>[0]); | | 6 | X_1079=<tmpr_7537>[0] := bat.reverse(X_941=nil); | | 24 | X_625=<tmp_7536>[0] := algebra.uselect(X_288=nil:bat[:oid,:str],A0="201110"); | | 5 | X_1419=<tmp_7467>[0] := bat.mirror(X_1319=nil); | | 26 | (X_1301=<tmp_7474>[0],X_1302) := group.done(X_1216=<tmp_7233>[0]); | | 46 | X_1226=<tmp_7252>[0] := algebra.leftjoin(X_1149=nil,X_595=nil); | | 19 | X_1401=<tmp_7467>[0] := bat.mirror(X_1301=nil); | | 26 | (X_1310=<tmp_7572>[0],X_1311) := group.done(X_1222=<tmp_7056>[0]); | | 13 | X_1395=<tmp_7433>[0] := bat.mirror(X_1295=nil); | | 19 | X_1436=<tmp_7155>[0] := algebra.leftjoin(X_1434=nil,X_1238=<tmp_6767>[0]); | | 16 | X_1397=<tmp_7372>[0] := algebra.leftjoin(X_1395=nil,X_1212=<tmp_7342>[0]); | | 17 | X_1404=<tmp_7566>[0] := bat.mirror(X_1304=nil); | | 6 | X_1422=<tmp_7606>[0] := bat.mirror(X_1322=nil); | | 24 | X_1406=<tmp_7337>[0] := algebra.leftjoin(X_1404=nil,X_1218=<tmp_7254>[0]); | | 4 | X_1389=<tmp_7567>[0] := bat.mirror(X_1289=nil); | | 34 | X_1179=<tmp_7134>[0] := algebra.leftjoin(X_1079=nil,X_548=nil); | | 27 | X_820=<tmp_7477>[0] := algebra.kunion(X_755=nil,X_625=nil); | | 24 | X_1421=<tmp_7220>[0] := algebra.leftjoin(X_1419=nil,X_1228=<tmp_7145>[0]); | | 23 | X_885=<tmp_7567>[0] := algebra.kdifference(X_820=nil,X_13=<tmpr_7003>[0]); | | 31 | (X_1316=<tmp_7474>[0],X_1317) := group.done(X_1226=<tmp_7252>[0]); | | 17 | X_1403=<tmp_7150>[0] := algebra.leftjoin(X_1401=nil,X_1216=<tmp_7233>[0]); | | 11026 | X_688=<tmp_7071>[0] := algebra.uselect(X_392=nil:bat[:oid,:str],A0="201110"); | | 14 | X_1410=<tmp_7467>[0] := bat.mirror(X_1310=nil); | | 19 | (X_1337=<tmp_7473>[0],X_1338) := group.done(X_1240=<tmp_7245>[0]); | | 14 | X_1413=<tmp_7436>[0] := bat.mirror(X_1313=nil); | | 20 | X_1424=<tmp_7303>[0] := algebra.leftjoin(X_1422=nil,X_1230=<tmp_7117>[0]); | | 21 | X_1391=<tmp_7273>[0] := algebra.leftjoin(X_1389=nil,X_1208=<tmp_7202>[0]); | | 21 | (X_1246=<tmp_7572>[0],X_1247) := group.done(X_1179=<tmp_7134>[0]); | | 3 | X_1164=<tmpr_7504>[0] := bat.reverse(X_1058=nil); | | 9 | X_963=<tmp_7606>[0] := algebra.markT(X_885=nil,33,5); | | 19 | X_1416=<tmp_7566>[0] := bat.mirror(X_1316=nil); | | 6 | X_1095=<tmpr_7606>[0] := bat.reverse(X_963=nil); | | 23 | X_1412=<tmp_7352>[0] := algebra.leftjoin(X_1410=nil,X_1222=<tmp_7056>[0]); | | 22 | X_1418=<tmp_7063>[0] := algebra.leftjoin(X_1416=nil,X_1226=<tmp_7252>[0]); | | 11326 | X_686=<tmp_7210>[0] := algebra.uselect(X_388=nil:bat[:oid,:str],A0="201110"); | | 18 | X_1415=<tmp_7361>[0] := algebra.leftjoin(X_1413=nil,X_1224=<tmp_7140>[0]); | | 10 | X_1346=<tmp_7436>[0] := bat.mirror(X_1246=nil); | | 36 | X_1236=<tmp_7166>[0] := algebra.leftjoin(X_1164=nil,X_605=nil); | | 23 | X_753=<tmp_7433>[0] := algebra.kdifference(X_688=nil,X_285=<tmpr_7527>:bat[:oid,:str][0]); | | 30 | X_1190=<tmp_7364>[0] := algebra.leftjoin(X_1095=nil,X_559=nil); | | 12 | X_1437=<tmp_7467>[0] := bat.mirror(X_1337=nil); | | 25 | X_751=<tmp_7566>[0] := algebra.kdifference(X_686=nil,X_282=<tmpr_7556>:bat[:oid,:str][0]); | | 18 | X_1349=<tmp_7115>[0] := algebra.leftjoin(X_1346=nil,X_1179=<tmp_7134>[0]); | | 11427 | X_684=<tmp_7373>[0] := algebra.uselect(X_385=nil:bat[:oid,:str],A0="201110"); | | 37 | X_621=<tmp_7436>[0] := algebra.uselect(X_282=nil:bat[:oid,:str],A0="201110"); | | 30 | X_623=<tmp_7536>[0] := algebra.uselect(X_285=nil:bat[:oid,:str],A0="201110"); | | 20 | (X_1262=<tmp_7473>[0],X_1263) := group.done(X_1190=<tmp_7364>[0]); | | 11080 | X_682=<tmp_7074>[0] := algebra.uselect(X_382=nil:bat[:oid,:str],A0="201110"); | | 9 | X_1362=<tmp_7536>[0] := bat.mirror(X_1262=nil); | | 21 | (X_1331=<tmp_7572>[0],X_1332) := group.done(X_1236=<tmp_7166>[0]); | | 22 | X_749=<tmp_7556>[0] := algebra.kdifference(X_684=nil,X_279=<tmpr_7507>:bat[:oid,:str][0]); | | 18 | X_747=<tmp_7433>[0] := algebra.kdifference(X_682=nil,X_276=<tmpr_7472>:bat[:oid,:str][0]); | | 6 | X_1431=<tmp_7536>[0] := bat.mirror(X_1331=nil); | | 59 | X_1439=<tmp_7362>[0] := algebra.leftjoin(X_1437=nil,X_1240=<tmp_7245>[0]); | | 13 | X_1364=<tmp_7213>[0] := algebra.leftjoin(X_1362=nil,X_1190=<tmp_7364>[0]); | | 11 | X_1433=<tmp_7366>[0] := algebra.leftjoin(X_1431=nil,X_1236=<tmp_7166>[0]); | | 22 | X_818=<tmp_7436>[0] := algebra.kunion(X_753=nil,X_623=nil); | | 23 | X_619=<tmp_7615>[0] := algebra.uselect(X_279=nil:bat[:oid,:str],A0="201110"); | | 21 | X_617=<tmp_7566>[0] := algebra.uselect(X_276=nil:bat[:oid,:str],A0="201110"); | | 22 | X_816=<tmp_7467>[0] := algebra.kunion(X_751=nil,X_621=nil); | | 11 | X_883=<tmp_7536>[0] := algebra.kdifference(X_818=nil,X_13=<tmpr_7003>[0]); | | 17 | X_814=<tmp_7436>[0] := algebra.kunion(X_749=nil,X_619=nil); | | 16 | X_812=<tmp_7615>[0] := algebra.kunion(X_747=nil,X_617=nil); | | 14 | X_881=<tmp_7566>[0] := algebra.kdifference(X_816=nil,X_13=<tmpr_7003>[0]); | | 16 | X_959=<tmp_7467>[0] := algebra.markT(X_883=nil,33,4); | | 10 | X_879=<tmp_7536>[0] := algebra.kdifference(X_814=nil,X_13=<tmpr_7003>[0]); | | 10 | X_877=<tmp_7436>[0] := algebra.kdifference(X_812=nil,X_13=<tmpr_7003>[0]); | | 4 | X_1092=<tmpr_7467>[0] := bat.reverse(X_959=nil); | | 11 | X_955=<tmp_7615>[0] := algebra.markT(X_881=nil,33,3); | | 14 | X_951=<tmp_7566>[0] := algebra.markT(X_879=nil,33,2); | | 10 | X_947=<tmp_7536>[0] := algebra.markT(X_877=nil,33,1); | | 24 | X_1188=<tmp_7331>[0] := algebra.leftjoin(X_1092=nil,X_557=nil); | | 8 | X_1089=<tmpr_7615>[0] := bat.reverse(X_955=nil); | | 4 | X_1086=<tmpr_7566>[0] := bat.reverse(X_951=nil); | | 4 | X_1083=<tmpr_7536>[0] := bat.reverse(X_947=nil); | | 14 | (X_1259=<tmp_7572>[0],X_1260) := group.done(X_1188=<tmp_7331>[0]); | | 33 | X_1186=<tmp_7136>[0] := algebra.leftjoin(X_1089=nil,X_555=nil); | | 23 | X_1184=<tmp_7076>[0] := algebra.leftjoin(X_1086=nil,X_553=nil); | | 5 | X_1359=<tmp_7547>[0] := bat.mirror(X_1259=nil); | | 20 | X_1182=<tmp_7354>[0] := algebra.leftjoin(X_1083=nil,X_551=nil); | | 20 | (X_1256=<tmp_7572>[0],X_1257) := group.done(X_1186=<tmp_7136>[0]); | | 14 | (X_1253=<tmp_7473>[0],X_1254) := group.done(X_1184=<tmp_7076>[0]); | | 13 | X_1361=<tmp_7205>[0] := algebra.leftjoin(X_1359=nil,X_1188=<tmp_7331>[0]); | | 14 | (X_1250=<tmp_7474>[0],X_1251) := group.done(X_1182=<tmp_7354>[0]); | | 4 | X_1353=<tmp_7616>[0] := bat.mirror(X_1253=nil); | | 7 | X_1356=<tmp_7547>[0] := bat.mirror(X_1256=nil); | | 6 | X_1350=<tmp_7536>[0] := bat.mirror(X_1250=nil); | | 11 | X_1355=<tmp_7270>[0] := algebra.leftjoin(X_1353=nil,X_1184=<tmp_7076>[0]); | | 10 | X_1358=<tmp_7010>[0] := algebra.leftjoin(X_1356=nil,X_1186=<tmp_7136>[0]); | | 11 | X_1352=<tmp_7045>[0] := algebra.leftjoin(X_1350=nil,X_1182=<tmp_7354>[0]); | | 22063 | X_702=<tmp_7514>[3206628] := algebra.uselect(X_415=nil:bat[:oid,:str],A0="201110"); | | 24 | X_767=<tmp_7536>[3206628] := algebra.kdifference(X_702=nil,X_309=<tmpr_7520>:bat[:oid,:str][0]); | | 23 | X_637=<tmp_7616>[0] := algebra.uselect(X_309=nil:bat[:oid,:str],A0="201110"); | | 15 | X_832=<tmp_7520>[3206628] := algebra.kunion(X_767=nil,X_637=nil); | | 8 | X_897=<tmp_7616>[3206628] := algebra.kdifference(X_832=nil,X_13=<tmpr_7003>[0]); | | 9 | X_988=<tmp_7520>[3206628] := algebra.markT(X_897=nil,33,11); | | 3 | X_1113=<tmpr_7520>[3206628] := bat.reverse(X_988=nil); | | 21002 | X_696=<tmp_7610>[3206628] := algebra.uselect(X_405=nil:bat[:oid,:str],A0="201110"); | | 374 | X_1202=<tmp_7536>[3206628] := algebra.leftjoin(X_1113=nil,X_571=nil); | | 20 | X_761=<tmp_7517>[3206628] := algebra.kdifference(X_696=nil,X_299=<tmpr_7614>:bat[:oid,:str][0]); | | 22 | X_631=<tmp_7570>[0] := algebra.uselect(X_299=nil:bat[:oid,:str],A0="201110"); | | 9 | X_826=<tmp_7614>[3206628] := algebra.kunion(X_761=nil,X_631=nil); | | 7 | X_891=<tmp_7570>[3206628] := algebra.kdifference(X_826=nil,X_13=<tmpr_7003>[0]); | | 8 | X_975=<tmp_7614>[3206628] := algebra.markT(X_891=nil,33,8); | | 2 | X_1104=<tmpr_7614>[3206628] := bat.reverse(X_975=nil); | | 351 | X_1196=<tmp_7517>[3206628] := algebra.leftjoin(X_1104=nil,X_565=nil); | | 21725 | X_692=<tmp_7156>[1442130] := algebra.uselect(X_399=nil:bat[:oid,:str],A0="201110"); | | 22 | X_757=<tmp_7545>[1442130] := algebra.kdifference(X_692=nil,X_292=<tmpr_7600>:bat[:oid,:str][0]); | | 18 | X_627=<tmp_7570>[0] := algebra.uselect(X_292=nil:bat[:oid,:str],A0="201110"); | | 8 | X_822=<tmp_7600>[1442130] := algebra.kunion(X_757=nil,X_627=nil); | | 7 | X_887=<tmp_7570>[1442130] := algebra.kdifference(X_822=nil,X_13=<tmpr_7003>[0]); | | 7 | X_967=<tmp_7600>[1442130] := algebra.markT(X_887=nil,33,6); | | 3 | X_1098=<tmpr_7600>[1442130] := bat.reverse(X_967=nil); | | 30872 | X_706=<tmp_7535>[2823445] := algebra.uselect(X_421=nil:bat[:oid,:str],A0="201110"); | | 22 | X_771=<tmp_7554>[2823445] := algebra.kdifference(X_706=nil,X_315=<tmpr_7515>:bat[:oid,:str][0]); | | 19 | X_641=<tmp_7614>[0] := algebra.uselect(X_315=nil:bat[:oid,:str],A0="201110"); | | 8 | X_836=<tmp_7515>[2823445] := algebra.kunion(X_771=nil,X_641=nil); | | 6 | X_901=<tmp_7614>[2823445] := algebra.kdifference(X_836=nil,X_13=<tmpr_7003>[0]); | | 6 | X_996=<tmp_7515>[2823445] := algebra.markT(X_901=nil,33,13); | | 2 | X_1119=<tmpr_7515>[2823445] := bat.reverse(X_996=nil); | | 76916 | X_700=<tmp_7531>[3206628] := algebra.uselect(X_412=nil:bat[:oid,:str],A0="201110"); | | 25 | X_765=<tmp_7605>[3206628] := algebra.kdifference(X_700=nil,X_305=<tmpr_7512>:bat[:oid,:str][0]); | | 20 | X_635=<tmp_7545>[0] := algebra.uselect(X_305=nil:bat[:oid,:str],A0="201110"); | | 9 | X_830=<tmp_7512>[3206628] := algebra.kunion(X_765=nil,X_635=nil); | | 8 | X_895=<tmp_7545>[3206628] := algebra.kdifference(X_830=nil,X_13=<tmpr_7003>[0]); | | 7 | X_984=<tmp_7512>[3206628] := algebra.markT(X_895=nil,33,10); | | 3 | X_1110=<tmpr_7512>[3206628] := bat.reverse(X_984=nil); | | 76513 | X_694=<tmp_7172>[3206628] := algebra.uselect(X_402=nil:bat[:oid,:str],A0="201110"); | | 2784 | X_1200=<tmp_7605>[3206628] := algebra.leftjoin(X_1110=nil,X_569=nil); | | 38 | X_759=<tmp_7453>[3206628] := algebra.kdifference(X_694=nil,X_296=<tmpr_7503>:bat[:oid,:str][0]); | | 39 | X_629=<tmp_7545>[0] := algebra.uselect(X_296=nil:bat[:oid,:str],A0="201110"); | | 9 | X_824=<tmp_7503>[3206628] := algebra.kunion(X_759=nil,X_629=nil); | | 7 | X_889=<tmp_7545>[3206628] := algebra.kdifference(X_824=nil,X_13=<tmpr_7003>[0]); | | 8 | X_971=<tmp_7503>[3206628] := algebra.markT(X_889=nil,33,7); | | 3 | X_1101=<tmpr_7503>[3206628] := bat.reverse(X_971=nil); | | 80268 | X_704=<tmp_7316>[3206628] := algebra.uselect(X_418=nil:bat[:oid,:str],A0="201110"); | | 107 | X_1194=<tmp_7545>[3206628] := algebra.leftjoin(X_1101=nil,X_563=nil); | | 28 | X_769=<tmp_7503>[3206628] := algebra.kdifference(X_704=nil,X_312=<tmpr_7534>:bat[:oid,:str][0]); | | 23 | X_639=<tmp_7453>[0] := algebra.uselect(X_312=nil:bat[:oid,:str],A0="201110"); | | 9 | X_834=<tmp_7534>[3206628] := algebra.kunion(X_769=nil,X_639=nil); | | 8 | X_899=<tmp_7453>[3206628] := algebra.kdifference(X_834=nil,X_13=<tmpr_7003>[0]); | | 8 | X_992=<tmp_7534>[3206628] := algebra.markT(X_899=nil,33,12); | | 3 | X_1116=<tmpr_7534>[3206628] := bat.reverse(X_992=nil); | | 162 | X_1204=<tmp_7503>[3206628] := algebra.leftjoin(X_1116=nil,X_573=nil); | | 86517 | X_698=<tmp_7317>[3206628] := algebra.uselect(X_409=nil:bat[:oid,:str],A0="201110"); | | 23 | X_763=<tmp_7560>[3206628] := algebra.kdifference(X_698=nil,X_302=<tmpr_7526>:bat[:oid,:str][0]); | | 22 | X_633=<tmp_7453>[0] := algebra.uselect(X_302=nil:bat[:oid,:str],A0="201110"); | | 9 | X_828=<tmp_7526>[3206628] := algebra.kunion(X_763=nil,X_633=nil); | | 7 | X_893=<tmp_7453>[3206628] := algebra.kdifference(X_828=nil,X_13=<tmpr_7003>[0]); | | 8 | X_939=<tmp_7526>[0] := algebra.kdifference(X_15=nil,X_13=nil); | | 6 | X_1074=<tmp_7521>[0] := algebra.markT(X_939=nil,33,32); | | 28 | X_980=<tmp_7526>[3206628] := algebra.markT(X_893=nil,33,9); | | 3 | X_1176=<tmpr_7521>[0] := bat.reverse(X_1074=nil); | | 4 | X_1107=<tmpr_7526>[3206628] := bat.reverse(X_980=nil); | | 16 | X_1244=<tmp_7173>[0] := algebra.leftjoin(X_1176=nil,X_6=nil:bat[:oid,:str]); | | 15 | (X_1343=<tmp_7474>[0],X_1344) := group.done(X_1244=<tmp_7173>[0]); | | 4 | X_1443=<tmp_7560>[0] := bat.mirror(X_1343=nil); | | 11 | X_1445=<tmp_7151>[0] := algebra.leftjoin(X_1443=nil,X_1244=<tmp_7173>[0]); | | 3776 | X_1198=<tmp_7453>[3206628] := algebra.leftjoin(X_1107=nil,X_567=nil); | | 181663 | X_1206=<tmp_7614>[2823445] := algebra.leftjoin(X_1119=nil,X_575=nil); | | 254769 | X_1192=<tmp_7570>[1442130] := algebra.leftjoin(X_1098=nil,X_561=nil); | | 187614021 | (X_1265=<tmp_7600>[1234833],X_1266) := group.done(X_1192=<tmp_7570>[1442130]); | | 17 | X_1365=<tmp_7242>[1234833] := bat.mirror(X_1265=nil); | | 49488 | X_1367=<tmp_7156>[1234833] := algebra.leftjoin(X_1365=nil,X_1192=<tmp_7570>[1442130]); | | 544752430 | (X_1286=<tmp_7600>[2220212],X_1287) := group.done(X_1206=<tmp_7614>[2823445]); | | 19 | X_1386=<tmp_7563>[2220212] := bat.mirror(X_1286=nil); | | 58910 | X_1388=<tmp_7535>[2220212] := algebra.leftjoin(X_1386=nil,X_1206=<tmp_7614>[2823445]); | | 644705881 | (X_1280=<tmp_7600>[2377413],X_1281) := group.done(X_1202=<tmp_7536>[3206628]); | | 17 | X_1380=<tmp_7514>[2377413] := bat.mirror(X_1280=nil); | | 71778 | X_1382=<tmp_7520>[2377413] := algebra.leftjoin(X_1380=nil,X_1202=<tmp_7536>[3206628]); | | 657495105 | (X_1277=<tmp_7600>[2465364],X_1278) := group.done(X_1200=<tmp_7605>[3206628]); | | 18 | X_1377=<tmp_7603>[2465364] := bat.mirror(X_1277=nil); | | 73725 | X_1379=<tmp_7531>[2465364] := algebra.leftjoin(X_1377=nil,X_1200=<tmp_7605>[3206628]); | | 811172850 | (X_1283=<tmp_7600>[2716427],X_1284) := group.done(X_1204=<tmp_7503>[3206628]); | | 17 | X_1383=<tmp_7447>[2716427] := bat.mirror(X_1283=nil); | | 84576 | X_1385=<tmp_7316>[2716427] := algebra.leftjoin(X_1383=nil,X_1204=<tmp_7503>[3206628]); | | 882864787 | (X_1268=<tmp_7600>[2683599],X_1269) := group.done(X_1194=<tmp_7545>[3206628]); | | 19 | X_1368=<tmp_7513>[2683599] := bat.mirror(X_1268=nil); | | 83375 | X_1370=<tmp_7172>[2683599] := algebra.leftjoin(X_1368=nil,X_1194=<tmp_7545>[3206628]); | | 946872080 | (X_1274=<tmp_7600>[2784911],X_1275) := group.done(X_1198=<tmp_7453>[3206628]); | | 15 | X_1374=<tmp_7505>[2784911] := bat.mirror(X_1274=nil); | | 68725 | X_1376=<tmp_7317>[2784911] := algebra.leftjoin(X_1374=nil,X_1198=<tmp_7453>[3206628]); | | 1059829885 | (X_1271=<tmp_7600>[2757955],X_1272) := group.done(X_1196=<tmp_7517>[3206628]); | | 17 | X_1371=<tmp_7522>[2757955] := bat.mirror(X_1271=nil); | | 81129 | X_1373=<tmp_7610>[2757955] := algebra.leftjoin(X_1371=nil,X_1196=<tmp_7517>[3206628]); | | 1351544935 | X_1446=<tmp_7600>[19240714] := mat.pack(X_1349=nil,X_1352=nil,X_1355=nil,X_1358=nil,X_1361=nil,X_1364=nil,X_1367=nil,X_1370=nil,X_1373=nil,X_1376=nil,X_1379=nil,X_1382=nil,X_1385= | : : nil,X_1388=nil,X_1391=nil,X_1394=nil,X_1397=nil,X_1400=nil,X_1403=nil,X_1406=nil,X_1409=nil,X_1412=nil,X_1415=nil,X_1418=nil,X_1421=nil,X_1424=nil,X_1427=nil,X_1430=nil,X_1433=nil : : : ,X_1436=nil,X_1439=nil,X_1442=nil,X_1445=nil); : | 16474997242 | (ext45=<tmp_7520>[5753724],grp43) := group.done(X_31=<tmp_7123>[21004266]); | | 31 | X_34=<tmp_7152>[5753724] := bat.mirror(ext45=nil); | | 348780 | X_35=<tmp_7067>[5753724] := algebra.leftjoin(X_34=nil,X_31=nil); | | 17 | X_36 := sql.resultSet(1,1,X_35=<tmp_7067>[5753724]); | | 10 | sql.rsColumn(X_36=0,"sys.f_global","datastore_systemid":str,"varchar",2048,0,X_35=nil); | | 2 | X_44 := io.stdout(); | | 1133709 | sql.exportResult(X_44=="44284288":streams,X_36=0); | | 8 | X_4 := sql.mvc(); | | 7 | X_22:bat[:oid,:str] =<tmp_6474>[102612097] := sql.bind(X_4=0,"sys","f_global","utc_timestamp",0); | | 4 | X_21:bat[:oid,:str] =<tmp_6530>[0] := sql.bind(X_4=0,"sys","f_global","utc_timestamp",2); | | 29 | X_23=<tmp_7123>[102612097] := algebra.kdifference(X_22=nil:bat[:oid,:str],X_21=<tmp_6530>:bat[:oid,:str][0]); | | 23 | X_24=<tmp_7520>[102612097] := algebra.kunion(X_23=nil,X_21=nil:bat[:oid,:str]); | | 4 | X_20:bat[:oid,:str] =<tmp_6531>[0] := sql.bind(X_4=0,"sys","f_global","utc_timestamp",1); | | 6 | X_25=<tmp_7123>[102612097] := algebra.kunion(X_24=nil,X_20=nil:bat[:oid,:str]); | | 4 | X_18:bat[:oid,:oid] =<tmp_6515>[0] := sql.bind_dbat(X_4=0,"sys","f_global",1); | | 3 | X_19=<tmpr_6515>[0] := bat.reverse(X_18=nil:bat[:oid,:oid]); | | 6 | X_26=<tmp_7520>[102612097] := algebra.kdifference(X_25=nil,X_19=nil); | | 32719239 | X_27:bat[:oid,:str] =<tmp_7123>[102612097] := batstr.substring(X_26=nil,A0=0,A1=7); | | 909537 | X_28=<tmp_7074>[23505343] := algebra.uselect(X_27=nil:bat[:oid,:str],A2="2011-10"); | | 34 | X_29=<tmp_7123>[23505343] := algebra.markT(X_28=nil,0@0:oid); | | 5 | X_30=<tmpr_7123>[23505343] := bat.reverse(X_29=nil); | | 21 | X_12:bat[:oid,:str] =<tmp_6453>[102612097] := sql.bind(X_4=0,"sys","f_global","datastore_systemid",0); | | 4 | X_10:bat[:oid,:str] =<tmp_6530>[0] := sql.bind(X_4=0,"sys","f_global","datastore_systemid",2); | | 15 | X_14=<tmp_7520>[102612097] := algebra.kdifference(X_12=nil:bat[:oid,:str],X_10=<tmp_6530>:bat[:oid,:str][0]); | | 17 | X_15=<tmp_7152>[102612097] := algebra.kunion(X_14=nil,X_10=nil:bat[:oid,:str]); | | 4 | X_7:bat[:oid,:str] =<tmp_6531>[0] := sql.bind(X_4=0,"sys","f_global","datastore_systemid",1); | | 7 | X_16=<tmp_7520>[102612097] := algebra.kunion(X_15=nil,X_7=nil:bat[:oid,:str]); | | 1035748 | X_31=<tmp_7152>[23505343] := algebra.leftjoin(X_30=nil,X_16=nil); | | 16569633433 | (ext43=<tmp_7123>[5941581],grp41) := group.done(X_1446=nil); | | 21 | X_18=<tmp_7600>[5941581] := bat.mirror(ext43=nil); | | 24 | X_1482=<tmp_7312>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1179=nil); | | 17 | X_1512=<tmp_7450>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1240=nil); | | 78 | X_1500=<tmp_7461>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1216=nil); | | 185 | X_1514=<tmp_7430>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1244=nil); | | 54 | X_1504=<tmp_7432>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1224=nil); | | 51 | X_1507=<tmp_7452>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1230=nil); | | 41 | X_1501=<tmp_7437>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1218=nil); | | 49 | X_1497=<tmp_7424>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1210=nil); | | 41 | X_1499=<tmp_7127>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1214=nil); | | 594 | X_1503=<tmp_7416>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1222=nil); | | 12 | X_1483=<tmp_7417>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1182=nil); | | 43 | X_1508=<tmp_7423>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1232=nil); | | 29 | X_1498=<tmp_7444>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1212=nil); | | 13 | X_1509=<tmp_7315>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1234=nil); | | 54 | X_1486=<tmp_7463>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1188=nil); | | 48 | X_1506=<tmp_7421>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1228=nil); | | 48 | X_1487=<tmp_7422>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1190=nil); | | 1093 | X_1510=<tmp_7176>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1236=nil); | | 22 | X_1485=<tmp_7434>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1186=nil); | | 1217 | X_1513=<tmp_7426>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1242=nil); | | 21 | X_1496=<tmp_7462>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1208=nil); | | 850 | X_1511=<tmp_7442>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1238=nil); | | 17 | X_1484=<tmp_7441>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1184=nil); | | 698 | X_1505=<tmp_7454>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1226=nil); | | 776 | X_1502=<tmp_7427>[0] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1220=nil); | | 123017 | X_1490=<tmp_7515>[1162175] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1196=nil); | | 137863 | X_1488=<tmp_7563>[1234833] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1192=nil); | | 151145 | X_1489=<tmp_7317>[2615092] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1194=nil); | | 181695 | X_1492=<tmp_7316>[124936] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1200=nil); | | 199435 | X_1494=<tmp_7513>[124675] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1204=nil); | | 216052 | X_1495=<tmp_7603>[124946] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1206=nil); | | 226358 | X_1493=<tmp_7522>[157125] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1202=nil); | | 357893 | X_1491=<tmp_7172>[397799] := algebra.leftjoin(X_18=<tmp_7600>[5941581],X_1198=nil); | | 45827059 | X_1481=<tmp_7453>[5941581] := mat.pack(X_1482=nil,X_1483=nil,X_1484=nil,X_1485=nil,X_1486=nil,X_1487=nil,X_1488=nil,X_1489=nil,X_1490=nil,X_1491=nil,X_1492=nil,X_1493=nil,X_1494=n | : : il,X_1495=nil,X_1496=nil,X_1497=nil,X_1498=nil,X_1499=nil,X_1500=nil,X_1501=nil,X_1502=nil,X_1503=nil,X_1504=nil,X_1505=nil,X_1506=nil,X_1507=nil,X_1508=nil,X_1509=nil,X_1510=nil, : : : X_1511=nil,X_1512=nil,X_1513=nil,X_1514=nil); : | 5558544 | X_19=<tmp_7603>[5941581] := algebra.leftjoin(X_18=nil,X_1481=nil); | | 19032872132 | barrier X_1515 := language.dataflow(); | | 21 | X_20 := sql.resultSet(1,",","\n",""","null",X_19=<tmp_7603>[5941581]); | | 10 | sql.rsColumn(X_20=3,"sys.f_sorted","uuid","varchar",2048,0,X_19=<tmp_7603>[5941581]); | | 5 | X_32 := str.codeset(); | | 14 | X_33 := str.iconv("/home/user/file":str,"UTF-8",X_32="UTF-8"); | | 115 | X_35 := streams.openWrite(X_33="/home/user/file"); | | 3849010 | sql.exportResult(X_35=="45961120":streams,X_20=3); | | 59 | streams.close(X_35=="45961120":streams); | | 35766 | X_38 := aggr.count(X_19=nil); | | 13 | sql.affectedRows(X_3=0,X_38=5941581:wrd,""); | | 19036757978 | X_5:void := user.s3_1("201110"); | +-------------+-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+ 635 tuples (317m 16s)
Here is also the explain query:
explain copy (select distinct(uuid) from f_sorted where yyyymm='201110') into '/home/user/file' USING DELIMITERS ',','\n','"' NULL as 'null'; +---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+ | mal | +===================================================================================================================================================================================================+ | function user.s4_1{autoCommit=true}():void; | | X_18 := nil:bat[:oid,:str]; | | barrier X_1515 := language.dataflow(); | | X_2 := sql.mvc(); | | X_378:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,0,32); | | X_679 := algebra.uselect(X_378,"201110":str); | | X_271:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,0,32); | | X_744 := algebra.kdifference(X_679,X_271); | | X_615 := algebra.uselect(X_271,"201110":str); | | X_809 := algebra.kunion(X_744,X_615); | | X_11:bat[:oid,:oid] := sql.bind_dbat(X_2,"sys","f_sorted",1); | | X_12 := bat.reverse(X_11); | | X_874 := algebra.kdifference(X_809,X_12); | | X_941 := algebra.markT(X_874,33,0); | | X_1079 := bat.reverse(X_941); | | X_165:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,0,32); | | X_59:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,0,32); | | X_483 := algebra.kdifference(X_165,X_59); | | X_548 := algebra.kunion(X_483,X_59); | | X_1179 := algebra.leftjoin(X_1079,X_548); | | (X_1246,X_1247) := group.done(X_1179); | | X_1346 := bat.mirror(X_1246); | | X_1349 := algebra.leftjoin(X_1346,X_1179); | | X_382:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,1,32); | | X_682 := algebra.uselect(X_382,"201110":str); | | X_276:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,1,32); | | X_747 := algebra.kdifference(X_682,X_276); | | X_617 := algebra.uselect(X_276,"201110":str); | | X_812 := algebra.kunion(X_747,X_617); | | X_877 := algebra.kdifference(X_812,X_12); | | X_947 := algebra.markT(X_877,33,1); | | X_1083 := bat.reverse(X_947); | | X_169:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,1,32); | | X_63:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,1,32); | | X_486 := algebra.kdifference(X_169,X_63); | | X_551 := algebra.kunion(X_486,X_63); | | X_1182 := algebra.leftjoin(X_1083,X_551); | | (X_1250,X_1251) := group.done(X_1182); | | X_1350 := bat.mirror(X_1250); | | X_1352 := algebra.leftjoin(X_1350,X_1182); | | X_385:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,2,32); | | X_684 := algebra.uselect(X_385,"201110":str); | | X_279:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,2,32); | | X_749 := algebra.kdifference(X_684,X_279); | | X_619 := algebra.uselect(X_279,"201110":str); | | X_814 := algebra.kunion(X_749,X_619); | | X_879 := algebra.kdifference(X_814,X_12); | | X_951 := algebra.markT(X_879,33,2); | | X_1086 := bat.reverse(X_951); | | X_172:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,2,32); | | X_66:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,2,32); | | X_488 := algebra.kdifference(X_172,X_66); | | X_553 := algebra.kunion(X_488,X_66); | | X_1184 := algebra.leftjoin(X_1086,X_553); | | (X_1253,X_1254) := group.done(X_1184); | | X_1353 := bat.mirror(X_1253); | | X_1355 := algebra.leftjoin(X_1353,X_1184); | | X_388:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,3,32); | | X_686 := algebra.uselect(X_388,"201110":str); | | X_282:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,3,32); | | X_751 := algebra.kdifference(X_686,X_282); | | X_621 := algebra.uselect(X_282,"201110":str); | | X_816 := algebra.kunion(X_751,X_621); | | X_881 := algebra.kdifference(X_816,X_12); | | X_955 := algebra.markT(X_881,33,3); | | X_1089 := bat.reverse(X_955); | | X_175:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,3,32); | | X_69:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,3,32); | | X_490 := algebra.kdifference(X_175,X_69); | | X_555 := algebra.kunion(X_490,X_69); | | X_1186 := algebra.leftjoin(X_1089,X_555); | | (X_1256,X_1257) := group.done(X_1186); | | X_1356 := bat.mirror(X_1256); | | X_1358 := algebra.leftjoin(X_1356,X_1186); | | X_392:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,4,32); | | X_688 := algebra.uselect(X_392,"201110":str); | | X_285:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,4,32); | | X_753 := algebra.kdifference(X_688,X_285); | | X_623 := algebra.uselect(X_285,"201110":str); | | X_818 := algebra.kunion(X_753,X_623); | | X_883 := algebra.kdifference(X_818,X_12); | | X_959 := algebra.markT(X_883,33,4); | | X_1092 := bat.reverse(X_959); | | X_179:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,4,32); | | X_72:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,4,32); | | X_492 := algebra.kdifference(X_179,X_72); | | X_557 := algebra.kunion(X_492,X_72); | | X_1188 := algebra.leftjoin(X_1092,X_557); | | (X_1259,X_1260) := group.done(X_1188); | | X_1359 := bat.mirror(X_1259); | | X_1361 := algebra.leftjoin(X_1359,X_1188); | | X_396:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,5,32); | | X_690 := algebra.uselect(X_396,"201110":str); | | X_288:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,5,32); | | X_755 := algebra.kdifference(X_690,X_288); | | X_625 := algebra.uselect(X_288,"201110":str); | | X_820 := algebra.kunion(X_755,X_625); | | X_885 := algebra.kdifference(X_820,X_12); | | X_963 := algebra.markT(X_885,33,5); | | X_1095 := bat.reverse(X_963); | | X_182:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,5,32); | | X_75:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,5,32); | | X_494 := algebra.kdifference(X_182,X_75); | | X_559 := algebra.kunion(X_494,X_75); | | X_1190 := algebra.leftjoin(X_1095,X_559); | | (X_1262,X_1263) := group.done(X_1190); | | X_1362 := bat.mirror(X_1262); | | X_1364 := algebra.leftjoin(X_1362,X_1190); | | X_399:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,6,32); | | X_692 := algebra.uselect(X_399,"201110":str); | | X_292:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,6,32); | | X_757 := algebra.kdifference(X_692,X_292); | | X_627 := algebra.uselect(X_292,"201110":str); | | X_822 := algebra.kunion(X_757,X_627); | | X_887 := algebra.kdifference(X_822,X_12); | | X_967 := algebra.markT(X_887,33,6); | | X_1098 := bat.reverse(X_967); | | X_185:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,6,32); | | X_79:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,6,32); | | X_496 := algebra.kdifference(X_185,X_79); | | X_561 := algebra.kunion(X_496,X_79); | | X_1192 := algebra.leftjoin(X_1098,X_561); | | (X_1265,X_1266) := group.done(X_1192); | | X_1365 := bat.mirror(X_1265); | | X_1367 := algebra.leftjoin(X_1365,X_1192); | | X_402:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,7,32); | | X_694 := algebra.uselect(X_402,"201110":str); | | X_296:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,7,32); | | X_759 := algebra.kdifference(X_694,X_296); | | X_629 := algebra.uselect(X_296,"201110":str); | | X_824 := algebra.kunion(X_759,X_629); | | X_889 := algebra.kdifference(X_824,X_12); | | X_971 := algebra.markT(X_889,33,7); | | X_1101 := bat.reverse(X_971); | | X_188:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,7,32); | | X_82:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,7,32); | | X_498 := algebra.kdifference(X_188,X_82); | | X_563 := algebra.kunion(X_498,X_82); | | X_1194 := algebra.leftjoin(X_1101,X_563); | | (X_1268,X_1269) := group.done(X_1194); | | X_1368 := bat.mirror(X_1268); | | X_1370 := algebra.leftjoin(X_1368,X_1194); | | X_405:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,8,32); | | X_696 := algebra.uselect(X_405,"201110":str); | | X_299:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,8,32); | | X_761 := algebra.kdifference(X_696,X_299); | | X_631 := algebra.uselect(X_299,"201110":str); | | X_826 := algebra.kunion(X_761,X_631); | | X_891 := algebra.kdifference(X_826,X_12); | | X_975 := algebra.markT(X_891,33,8); | | X_1104 := bat.reverse(X_975); | | X_192:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,8,32); | | X_85:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,8,32); | | X_500 := algebra.kdifference(X_192,X_85); | | X_565 := algebra.kunion(X_500,X_85); | | X_1196 := algebra.leftjoin(X_1104,X_565); | | (X_1271,X_1272) := group.done(X_1196); | | X_1371 := bat.mirror(X_1271); | | X_1373 := algebra.leftjoin(X_1371,X_1196); | | X_409:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,9,32); | | X_698 := algebra.uselect(X_409,"201110":str); | | X_302:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,9,32); | | X_763 := algebra.kdifference(X_698,X_302); | | X_633 := algebra.uselect(X_302,"201110":str); | | X_828 := algebra.kunion(X_763,X_633); | | X_893 := algebra.kdifference(X_828,X_12); | | X_980 := algebra.markT(X_893,33,9); | | X_1107 := bat.reverse(X_980); | | X_196:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,9,32); | | X_88:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,9,32); | | X_502 := algebra.kdifference(X_196,X_88); | | X_567 := algebra.kunion(X_502,X_88); | | X_1198 := algebra.leftjoin(X_1107,X_567); | | (X_1274,X_1275) := group.done(X_1198); | | X_1374 := bat.mirror(X_1274); | | X_1376 := algebra.leftjoin(X_1374,X_1198); | | X_412:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,10,32); | | X_700 := algebra.uselect(X_412,"201110":str); | | X_305:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,10,32); | | X_765 := algebra.kdifference(X_700,X_305); | | X_635 := algebra.uselect(X_305,"201110":str); | | X_830 := algebra.kunion(X_765,X_635); | | X_895 := algebra.kdifference(X_830,X_12); | | X_984 := algebra.markT(X_895,33,10); | | X_1110 := bat.reverse(X_984); | | X_199:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,10,32); | | X_92:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,10,32); | | X_504 := algebra.kdifference(X_199,X_92); | | X_569 := algebra.kunion(X_504,X_92); | | X_1200 := algebra.leftjoin(X_1110,X_569); | | (X_1277,X_1278) := group.done(X_1200); | | X_1377 := bat.mirror(X_1277); | | X_1379 := algebra.leftjoin(X_1377,X_1200); | | X_415:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,11,32); | | X_702 := algebra.uselect(X_415,"201110":str); | | X_309:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,11,32); | | X_767 := algebra.kdifference(X_702,X_309); | | X_637 := algebra.uselect(X_309,"201110":str); | | X_832 := algebra.kunion(X_767,X_637); | | X_897 := algebra.kdifference(X_832,X_12); | | X_988 := algebra.markT(X_897,33,11); | | X_1113 := bat.reverse(X_988); | | X_202:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,11,32); | | X_96:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,11,32); | | X_506 := algebra.kdifference(X_202,X_96); | | X_571 := algebra.kunion(X_506,X_96); | | X_1202 := algebra.leftjoin(X_1113,X_571); | | (X_1280,X_1281) := group.done(X_1202); | | X_1380 := bat.mirror(X_1280); | | X_1382 := algebra.leftjoin(X_1380,X_1202); | | X_418:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,12,32); | | X_704 := algebra.uselect(X_418,"201110":str); | | X_312:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,12,32); | | X_769 := algebra.kdifference(X_704,X_312); | | X_639 := algebra.uselect(X_312,"201110":str); | | X_834 := algebra.kunion(X_769,X_639); | | X_899 := algebra.kdifference(X_834,X_12); | | X_992 := algebra.markT(X_899,33,12); | | X_1116 := bat.reverse(X_992); | | X_205:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,12,32); | | X_99:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,12,32); | | X_508 := algebra.kdifference(X_205,X_99); | | X_573 := algebra.kunion(X_508,X_99); | | X_1204 := algebra.leftjoin(X_1116,X_573); | | (X_1283,X_1284) := group.done(X_1204); | | X_1383 := bat.mirror(X_1283); | | X_1385 := algebra.leftjoin(X_1383,X_1204); | | X_421:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,13,32); | | X_706 := algebra.uselect(X_421,"201110":str); | | X_315:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,13,32); | | X_771 := algebra.kdifference(X_706,X_315); | | X_641 := algebra.uselect(X_315,"201110":str); | | X_836 := algebra.kunion(X_771,X_641); | | X_901 := algebra.kdifference(X_836,X_12); | | X_996 := algebra.markT(X_901,33,13); | | X_1119 := bat.reverse(X_996); | | X_208:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,13,32); | | X_102:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,13,32); | | X_510 := algebra.kdifference(X_208,X_102); | | X_575 := algebra.kunion(X_510,X_102); | | X_1206 := algebra.leftjoin(X_1119,X_575); | | (X_1286,X_1287) := group.done(X_1206); | | X_1386 := bat.mirror(X_1286); | | X_1388 := algebra.leftjoin(X_1386,X_1206); | | X_425:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,14,32); | | X_708 := algebra.uselect(X_425,"201110":str); | | X_318:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,14,32); | | X_773 := algebra.kdifference(X_708,X_318); | | X_643 := algebra.uselect(X_318,"201110":str); | | X_838 := algebra.kunion(X_773,X_643); | | X_903 := algebra.kdifference(X_838,X_12); | | X_1000 := algebra.markT(X_903,33,14); | | X_1122 := bat.reverse(X_1000); | | X_212:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,14,32); | | X_105:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,14,32); | | X_512 := algebra.kdifference(X_212,X_105); | | X_577 := algebra.kunion(X_512,X_105); | | X_1208 := algebra.leftjoin(X_1122,X_577); | | (X_1289,X_1290) := group.done(X_1208); | | X_1389 := bat.mirror(X_1289); | | X_1391 := algebra.leftjoin(X_1389,X_1208); | | X_429:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,15,32); | | X_710 := algebra.uselect(X_429,"201110":str); | | X_321:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,15,32); | | X_775 := algebra.kdifference(X_710,X_321); | | X_645 := algebra.uselect(X_321,"201110":str); | | X_840 := algebra.kunion(X_775,X_645); | | X_905 := algebra.kdifference(X_840,X_12); | | X_1004 := algebra.markT(X_905,33,15); | | X_1125 := bat.reverse(X_1004); | | X_215:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,15,32); | | X_108:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,15,32); | | X_514 := algebra.kdifference(X_215,X_108); | | X_579 := algebra.kunion(X_514,X_108); | | X_1210 := algebra.leftjoin(X_1125,X_579); | | (X_1292,X_1293) := group.done(X_1210); | | X_1392 := bat.mirror(X_1292); | | X_1394 := algebra.leftjoin(X_1392,X_1210); | | X_432:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,16,32); | | X_712 := algebra.uselect(X_432,"201110":str); | | X_325:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,16,32); | | X_777 := algebra.kdifference(X_712,X_325); | | X_647 := algebra.uselect(X_325,"201110":str); | | X_842 := algebra.kunion(X_777,X_647); | | X_907 := algebra.kdifference(X_842,X_12); | | X_1008 := algebra.markT(X_907,33,16); | | X_1128 := bat.reverse(X_1008); | | X_218:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,16,32); | | X_112:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,16,32); | | X_516 := algebra.kdifference(X_218,X_112); | | X_581 := algebra.kunion(X_516,X_112); | | X_1212 := algebra.leftjoin(X_1128,X_581); | | (X_1295,X_1296) := group.done(X_1212); | | X_1395 := bat.mirror(X_1295); | | X_1397 := algebra.leftjoin(X_1395,X_1212); | | X_435:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,17,32); | | X_714 := algebra.uselect(X_435,"201110":str); | | X_329:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,17,32); | | X_779 := algebra.kdifference(X_714,X_329); | | X_649 := algebra.uselect(X_329,"201110":str); | | X_844 := algebra.kunion(X_779,X_649); | | X_909 := algebra.kdifference(X_844,X_12); | | X_1013 := algebra.markT(X_909,33,17); | | X_1131 := bat.reverse(X_1013); | | X_221:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,17,32); | | X_115:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,17,32); | | X_518 := algebra.kdifference(X_221,X_115); | | X_583 := algebra.kunion(X_518,X_115); | | X_1214 := algebra.leftjoin(X_1131,X_583); | | (X_1298,X_1299) := group.done(X_1214); | | X_1398 := bat.mirror(X_1298); | | X_1400 := algebra.leftjoin(X_1398,X_1214); | | X_438:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,18,32); | | X_716 := algebra.uselect(X_438,"201110":str); | | X_332:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,18,32); | | X_781 := algebra.kdifference(X_716,X_332); | | X_651 := algebra.uselect(X_332,"201110":str); | | X_846 := algebra.kunion(X_781,X_651); | | X_911 := algebra.kdifference(X_846,X_12); | | X_1017 := algebra.markT(X_911,33,18); | | X_1134 := bat.reverse(X_1017); | | X_225:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,18,32); | | X_118:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,18,32); | | X_520 := algebra.kdifference(X_225,X_118); | | X_585 := algebra.kunion(X_520,X_118); | | X_1216 := algebra.leftjoin(X_1134,X_585); | | (X_1301,X_1302) := group.done(X_1216); | | X_1401 := bat.mirror(X_1301); | | X_1403 := algebra.leftjoin(X_1401,X_1216); | | X_442:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,19,32); | | X_718 := algebra.uselect(X_442,"201110":str); | | X_335:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,19,32); | | X_783 := algebra.kdifference(X_718,X_335); | | X_653 := algebra.uselect(X_335,"201110":str); | | X_848 := algebra.kunion(X_783,X_653); | | X_913 := algebra.kdifference(X_848,X_12); | | X_1021 := algebra.markT(X_913,33,19); | | X_1137 := bat.reverse(X_1021); | | X_229:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,19,32); | | X_121:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,19,32); | | X_522 := algebra.kdifference(X_229,X_121); | | X_587 := algebra.kunion(X_522,X_121); | | X_1218 := algebra.leftjoin(X_1137,X_587); | | (X_1304,X_1305) := group.done(X_1218); | | X_1404 := bat.mirror(X_1304); | | X_1406 := algebra.leftjoin(X_1404,X_1218); | | X_445:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,20,32); | | X_720 := algebra.uselect(X_445,"201110":str); | | X_338:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,20,32); | | X_785 := algebra.kdifference(X_720,X_338); | | X_655 := algebra.uselect(X_338,"201110":str); | | X_850 := algebra.kunion(X_785,X_655); | | X_915 := algebra.kdifference(X_850,X_12); | | X_1025 := algebra.markT(X_915,33,20); | | X_1140 := bat.reverse(X_1025); | | X_232:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,20,32); | | X_125:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,20,32); | | X_524 := algebra.kdifference(X_232,X_125); | | X_589 := algebra.kunion(X_524,X_125); | | X_1220 := algebra.leftjoin(X_1140,X_589); | | (X_1307,X_1308) := group.done(X_1220); | | X_1407 := bat.mirror(X_1307); | | X_1409 := algebra.leftjoin(X_1407,X_1220); | | X_448:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,21,32); | | X_722 := algebra.uselect(X_448,"201110":str); | | X_342:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,21,32); | | X_787 := algebra.kdifference(X_722,X_342); | | X_657 := algebra.uselect(X_342,"201110":str); | | X_852 := algebra.kunion(X_787,X_657); | | X_917 := algebra.kdifference(X_852,X_12); | | X_1029 := algebra.markT(X_917,33,21); | | X_1143 := bat.reverse(X_1029); | | X_235:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,21,32); | | X_129:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,21,32); | | X_526 := algebra.kdifference(X_235,X_129); | | X_591 := algebra.kunion(X_526,X_129); | | X_1222 := algebra.leftjoin(X_1143,X_591); | | (X_1310,X_1311) := group.done(X_1222); | | X_1410 := bat.mirror(X_1310); | | X_1412 := algebra.leftjoin(X_1410,X_1222); | | X_451:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,22,32); | | X_724 := algebra.uselect(X_451,"201110":str); | | X_345:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,22,32); | | X_789 := algebra.kdifference(X_724,X_345); | | X_659 := algebra.uselect(X_345,"201110":str); | | X_854 := algebra.kunion(X_789,X_659); | | X_919 := algebra.kdifference(X_854,X_12); | | X_1033 := algebra.markT(X_919,33,22); | | X_1146 := bat.reverse(X_1033); | | X_238:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,22,32); | | X_132:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,22,32); | | X_528 := algebra.kdifference(X_238,X_132); | | X_593 := algebra.kunion(X_528,X_132); | | X_1224 := algebra.leftjoin(X_1146,X_593); | | (X_1313,X_1314) := group.done(X_1224); | | X_1413 := bat.mirror(X_1313); | | X_1415 := algebra.leftjoin(X_1413,X_1224); | | X_454:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,23,32); | | X_726 := algebra.uselect(X_454,"201110":str); | | X_348:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,23,32); | | X_791 := algebra.kdifference(X_726,X_348); | | X_661 := algebra.uselect(X_348,"201110":str); | | X_856 := algebra.kunion(X_791,X_661); | | X_921 := algebra.kdifference(X_856,X_12); | | X_1037 := algebra.markT(X_921,33,23); | | X_1149 := bat.reverse(X_1037); | | X_241:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,23,32); | | X_135:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,23,32); | | X_530 := algebra.kdifference(X_241,X_135); | | X_595 := algebra.kunion(X_530,X_135); | | X_1226 := algebra.leftjoin(X_1149,X_595); | | (X_1316,X_1317) := group.done(X_1226); | | X_1416 := bat.mirror(X_1316); | | X_1418 := algebra.leftjoin(X_1416,X_1226); | | X_458:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,24,32); | | X_728 := algebra.uselect(X_458,"201110":str); | | X_351:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,24,32); | | X_793 := algebra.kdifference(X_728,X_351); | | X_663 := algebra.uselect(X_351,"201110":str); | | X_858 := algebra.kunion(X_793,X_663); | | X_923 := algebra.kdifference(X_858,X_12); | | X_1041 := algebra.markT(X_923,33,24); | | X_1152 := bat.reverse(X_1041); | | X_245:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,24,32); | | X_138:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,24,32); | | X_532 := algebra.kdifference(X_245,X_138); | | X_597 := algebra.kunion(X_532,X_138); | | X_1228 := algebra.leftjoin(X_1152,X_597); | | (X_1319,X_1320) := group.done(X_1228); | | X_1419 := bat.mirror(X_1319); | | X_1421 := algebra.leftjoin(X_1419,X_1228); | | X_462:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,25,32); | | X_730 := algebra.uselect(X_462,"201110":str); | | X_354:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,25,32); | | X_795 := algebra.kdifference(X_730,X_354); | | X_665 := algebra.uselect(X_354,"201110":str); | | X_860 := algebra.kunion(X_795,X_665); | | X_925 := algebra.kdifference(X_860,X_12); | | X_1046 := algebra.markT(X_925,33,25); | | X_1155 := bat.reverse(X_1046); | | X_248:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,25,32); | | X_141:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,25,32); | | X_534 := algebra.kdifference(X_248,X_141); | | X_599 := algebra.kunion(X_534,X_141); | | X_1230 := algebra.leftjoin(X_1155,X_599); | | (X_1322,X_1323) := group.done(X_1230); | | X_1422 := bat.mirror(X_1322); | | X_1424 := algebra.leftjoin(X_1422,X_1230); | | X_465:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,26,32); | | X_732 := algebra.uselect(X_465,"201110":str); | | X_358:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,26,32); | | X_797 := algebra.kdifference(X_732,X_358); | | X_667 := algebra.uselect(X_358,"201110":str); | | X_862 := algebra.kunion(X_797,X_667); | | X_927 := algebra.kdifference(X_862,X_12); | | X_1050 := algebra.markT(X_927,33,26); | | X_1158 := bat.reverse(X_1050); | | X_251:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,26,32); | | X_145:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,26,32); | | X_536 := algebra.kdifference(X_251,X_145); | | X_601 := algebra.kunion(X_536,X_145); | | X_1232 := algebra.leftjoin(X_1158,X_601); | | (X_1325,X_1326) := group.done(X_1232); | | X_1425 := bat.mirror(X_1325); | | X_1427 := algebra.leftjoin(X_1425,X_1232); | | X_468:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,27,32); | | X_734 := algebra.uselect(X_468,"201110":str); | | X_362:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,27,32); | | X_799 := algebra.kdifference(X_734,X_362); | | X_669 := algebra.uselect(X_362,"201110":str); | | X_864 := algebra.kunion(X_799,X_669); | | X_929 := algebra.kdifference(X_864,X_12); | | X_1054 := algebra.markT(X_929,33,27); | | X_1161 := bat.reverse(X_1054); | | X_254:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,27,32); | | X_148:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,27,32); | | X_538 := algebra.kdifference(X_254,X_148); | | X_603 := algebra.kunion(X_538,X_148); | | X_1234 := algebra.leftjoin(X_1161,X_603); | | (X_1328,X_1329) := group.done(X_1234); | | X_1428 := bat.mirror(X_1328); | | X_1430 := algebra.leftjoin(X_1428,X_1234); | | X_471:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,28,32); | | X_736 := algebra.uselect(X_471,"201110":str); | | X_365:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,28,32); | | X_801 := algebra.kdifference(X_736,X_365); | | X_671 := algebra.uselect(X_365,"201110":str); | | X_866 := algebra.kunion(X_801,X_671); | | X_931 := algebra.kdifference(X_866,X_12); | | X_1058 := algebra.markT(X_931,33,28); | | X_1164 := bat.reverse(X_1058); | | X_258:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,28,32); | | X_151:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,28,32); | | X_540 := algebra.kdifference(X_258,X_151); | | X_605 := algebra.kunion(X_540,X_151); | | X_1236 := algebra.leftjoin(X_1164,X_605); | | (X_1331,X_1332) := group.done(X_1236); | | X_1431 := bat.mirror(X_1331); | | X_1433 := algebra.leftjoin(X_1431,X_1236); | | X_475:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,29,32); | | X_738 := algebra.uselect(X_475,"201110":str); | | X_368:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,29,32); | | X_803 := algebra.kdifference(X_738,X_368); | | X_673 := algebra.uselect(X_368,"201110":str); | | X_868 := algebra.kunion(X_803,X_673); | | X_933 := algebra.kdifference(X_868,X_12); | | X_1062 := algebra.markT(X_933,33,29); | | X_1167 := bat.reverse(X_1062); | | X_262:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,29,32); | | X_154:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,29,32); | | X_542 := algebra.kdifference(X_262,X_154); | | X_607 := algebra.kunion(X_542,X_154); | | X_1238 := algebra.leftjoin(X_1167,X_607); | | (X_1334,X_1335) := group.done(X_1238); | | X_1434 := bat.mirror(X_1334); | | X_1436 := algebra.leftjoin(X_1434,X_1238); | | X_478:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,30,32); | | X_740 := algebra.uselect(X_478,"201110":str); | | X_371:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,30,32); | | X_805 := algebra.kdifference(X_740,X_371); | | X_675 := algebra.uselect(X_371,"201110":str); | | X_870 := algebra.kunion(X_805,X_675); | | X_935 := algebra.kdifference(X_870,X_12); | | X_1066 := algebra.markT(X_935,33,30); | | X_1170 := bat.reverse(X_1066); | | X_265:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,30,32); | | X_158:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,30,32); | | X_544 := algebra.kdifference(X_265,X_158); | | X_609 := algebra.kunion(X_544,X_158); | | X_1240 := algebra.leftjoin(X_1170,X_609); | | (X_1337,X_1338) := group.done(X_1240); | | X_1437 := bat.mirror(X_1337); | | X_1439 := algebra.leftjoin(X_1437,X_1240); | | X_481:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0,31,32); | | X_742 := algebra.uselect(X_481,"201110":str); | | X_375:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2,31,32); | | X_807 := algebra.kdifference(X_742,X_375); | | X_677 := algebra.uselect(X_375,"201110":str); | | X_872 := algebra.kunion(X_807,X_677); | | X_937 := algebra.kdifference(X_872,X_12); | | X_1070 := algebra.markT(X_937,33,31); | | X_1173 := bat.reverse(X_1070); | | X_268:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0,31,32); | | X_162:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2,31,32); | | X_546 := algebra.kdifference(X_268,X_162); | | X_611 := algebra.kunion(X_546,X_162); | | X_1242 := algebra.leftjoin(X_1173,X_611); | | (X_1340,X_1341) := group.done(X_1242); | | X_1440 := bat.mirror(X_1340); | | X_1442 := algebra.leftjoin(X_1440,X_1242); | | X_13:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",1); | | X_14 := algebra.uselect(X_13,"201110":str); | | X_939 := algebra.kdifference(X_14,X_12); | | X_1074 := algebra.markT(X_939,33,32); | | X_1176 := bat.reverse(X_1074); | | X_5:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",1); | | X_1244 := algebra.leftjoin(X_1176,X_5); | | (X_1343,X_1344) := group.done(X_1244); | | X_1443 := bat.mirror(X_1343); | | X_1445 := algebra.leftjoin(X_1443,X_1244); | | X_1446 := mat.pack(X_1349,X_1352,X_1355,X_1358,X_1361,X_1364,X_1367,X_1370,X_1373,X_1376,X_1379,X_1382,X_1385,X_1388,X_1391,X_1394,X_1397,X_1400,X_1403,X_1406,X_1409,X_1412,X_1415,X_1418,X_ | : 1421,X_1424,X_1427,X_1430,X_1433,X_1436,X_1439,X_1442,X_1445); : | (ext46,grp44) := group.done(X_1446); | | X_17 := bat.mirror(ext46); | | X_1482 := algebra.leftjoin(X_17,X_1179); | | X_1483 := algebra.leftjoin(X_17,X_1182); | | X_1484 := algebra.leftjoin(X_17,X_1184); | | X_1485 := algebra.leftjoin(X_17,X_1186); | | X_1486 := algebra.leftjoin(X_17,X_1188); | | X_1487 := algebra.leftjoin(X_17,X_1190); | | X_1488 := algebra.leftjoin(X_17,X_1192); | | X_1489 := algebra.leftjoin(X_17,X_1194); | | X_1490 := algebra.leftjoin(X_17,X_1196); | | X_1491 := algebra.leftjoin(X_17,X_1198); | | X_1492 := algebra.leftjoin(X_17,X_1200); | | X_1493 := algebra.leftjoin(X_17,X_1202); | | X_1494 := algebra.leftjoin(X_17,X_1204); | | X_1495 := algebra.leftjoin(X_17,X_1206); | | X_1496 := algebra.leftjoin(X_17,X_1208); | | X_1497 := algebra.leftjoin(X_17,X_1210); | | X_1498 := algebra.leftjoin(X_17,X_1212); | | X_1499 := algebra.leftjoin(X_17,X_1214); | | X_1500 := algebra.leftjoin(X_17,X_1216); | | X_1501 := algebra.leftjoin(X_17,X_1218); | | X_1502 := algebra.leftjoin(X_17,X_1220); | | X_1503 := algebra.leftjoin(X_17,X_1222); | | X_1504 := algebra.leftjoin(X_17,X_1224); | | X_1505 := algebra.leftjoin(X_17,X_1226); | | X_1506 := algebra.leftjoin(X_17,X_1228); | | X_1507 := algebra.leftjoin(X_17,X_1230); | | X_1508 := algebra.leftjoin(X_17,X_1232); | | X_1509 := algebra.leftjoin(X_17,X_1234); | | X_1510 := algebra.leftjoin(X_17,X_1236); | | X_1511 := algebra.leftjoin(X_17,X_1238); | | X_1512 := algebra.leftjoin(X_17,X_1240); | | X_1513 := algebra.leftjoin(X_17,X_1242); | | X_1514 := algebra.leftjoin(X_17,X_1244); | | X_1481 := mat.pack(X_1482,X_1483,X_1484,X_1485,X_1486,X_1487,X_1488,X_1489,X_1490,X_1491,X_1492,X_1493,X_1494,X_1495,X_1496,X_1497,X_1498,X_1499,X_1500,X_1501,X_1502,X_1503,X_1504,X_1505,X_ | : 1506,X_1507,X_1508,X_1509,X_1510,X_1511,X_1512,X_1513,X_1514); : | X_18 := algebra.leftjoin(X_17,X_1481); | | exit X_1515; | | X_19 := sql.resultSet(1,",","\n",""","null",X_18); | | sql.rsColumn(X_19,"sys.f_sorted","uuid","varchar",2048,0,X_18); | | X_31 := str.codeset(); | | X_32 := str.iconv("/home/user/file":str,"UTF-8",X_31); | | X_34 := streams.openWrite(X_32); | | sql.exportResult(X_34,X_19); | | streams.close(X_34); | | X_37 := aggr.count(X_18); | | sql.affectedRows(X_2,X_37,""); | | end s4_1; | +---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+ 609 tuples (9.370ms)
Niels Nes wrote:
On Fri, Feb 10, 2012 at 09:51:45AM -0800, zack_pcd wrote:
The copy into query finished in 317 minutes. The volume we use is 63% full. However the copy-into query does not start writing in the first few hours (I don't see the file getting created). In fact, I see almost no disk usage, and the query is only using 1 or 2 cores out of 32 (nthreads=32). I'll try to run a trace of the copy-into as well but that will take a while. I'm using the default_pipe in the dec2011 release. I don't think I've actually changed any of the default settings.
Trace and explain of the count distinct query:
Could you also send the plan and explain of the copy into statements?
Niels
sql>explain select count(distinct uuid) from f_sorted where yyyymm='201110'; +-------------------------------------------------------------------------------------+ | mal | +=====================================================================================+ | function user.s7_1{autoCommit=true}():void; | | X_2 := sql.mvc(); | | X_23:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",0); | | X_25 := algebra.uselect(X_23,"201110":str); | | X_21:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",2); | | X_26 := algebra.kdifference(X_25,X_21); | | X_22 := algebra.uselect(X_21,"201110":str); | | X_27 := algebra.kunion(X_26,X_22); | | X_19:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","yyyymm",1); | | X_20 := algebra.uselect(X_19,"201110":str); | | X_28 := algebra.kunion(X_27,X_20); | | X_16:bat[:oid,:oid] := sql.bind_dbat(X_2,"sys","f_sorted",1); | | X_17 := bat.reverse(X_16); | | X_29 := algebra.kdifference(X_28,X_17); | | X_30 := algebra.markT(X_29,0@0:oid); | | X_31 := bat.reverse(X_30); | | X_10:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0); | | X_8:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2); | | X_12 := algebra.kdifference(X_10,X_8); | | X_13 := algebra.kunion(X_12,X_8); | | X_4:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",1); | | X_14 := algebra.kunion(X_13,X_4); | | X_32 := algebra.leftjoin(X_31,X_14); | | X_33 := algebra.selectNotNil(X_32); | | X_34 := bat.reverse(X_33); | | X_35 := algebra.kunique(X_34); | | X_36 := bat.reverse(X_35); | | X_37 := aggr.count(X_36); | | sql.exportValue(1,"sys.f_sorted","L7":str,"wrd",64,0,6,X_37,""); | | end s7_1; | +-------------------------------------------------------------------------------------+ 30 tuples (1.278ms) sql>trace select count(distinct uuid) from f_sorted where yyyymm='201110'; +---------+ | L10 | +=========+ | 5941581 | +---------+ 1 tuple (27.3s) +----------+--------------------------------------------------------------------------------------------------------------+ | ticks | stmt | +==========+==============================================================================================================+ | 6 | X_3 := sql.mvc(); | | 12 | X_23:bat[:oid,:str] =<tmp_7256>[102612097] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",0); | | 2497718 | X_24=<tmp_7425>[23505343] := algebra.uselect(X_23=nil:bat[:oid,:str],A0="201110"); | | 21 | X_21:bat[:oid,:str] =<tmp_6530>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",2); | | 28 | X_25=<tmp_7174>[23505343] := algebra.kdifference(X_24=nil,X_21=<tmp_6530>:bat[:oid,:str][0]); | | 29 | X_22=<tmp_7340>[0] := algebra.uselect(X_21=nil:bat[:oid,:str],A0="201110"); | | 10 | X_26=<tmp_7435>[23505343] := algebra.kunion(X_25=nil,X_22=nil); | | 5 | X_19:bat[:oid,:str] =<tmp_7013>[0] := sql.bind(X_3=0,"sys","f_sorted","yyyymm",1); | | 11 | X_20=<tmp_7174>[0] := algebra.uselect(X_19=nil:bat[:oid,:str],A0="201110"); | | 9 | X_27=<tmp_7340>[23505343] := algebra.kunion(X_26=nil,X_20=nil); | | 6 | X_17:bat[:oid,:oid] =<tmp_7003>[0] := sql.bind_dbat(X_3=0,"sys","f_sorted",1); | | 4 | X_18=<tmpr_7003>[0] := bat.reverse(X_17=nil:bat[:oid,:oid]); | | 5 | X_28=<tmp_7174>[23505343] := algebra.kdifference(X_27=nil,X_18=nil); | | 7 | X_29=<tmp_7340>[23505343] := algebra.markT(X_28=nil,0@0:oid); | | 3 | X_30=<tmpr_7340>[23505343] := bat.reverse(X_29=nil); | | 12 | X_11:bat[:oid,:str] =<tmp_7027>[102612097] := sql.bind(X_3=0,"sys","f_sorted","uuid",0); | | 3 | X_9:bat[:oid,:str] =<tmp_6530>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",2); | | 9 | X_13=<tmp_7174>[102612097] := algebra.kdifference(X_11=nil:bat[:oid,:str],X_9=<tmp_6530>:bat[:oid,:str][0]); | | 9 | X_14=<tmp_7435>[102612097] := algebra.kunion(X_13=nil,X_9=nil:bat[:oid,:str]); | | 4 | X_5:bat[:oid,:str] =<tmp_7326>[0] := sql.bind(X_3=0,"sys","f_sorted","uuid",1); | | 7 | X_15=<tmp_7174>[102612097] := algebra.kunion(X_14=nil,X_5=nil:bat[:oid,:str]); | | 885318 | X_31=<tmp_7435>[23505343] := algebra.leftjoin(X_30=nil,X_15=nil); | | 12 | X_32=<tmp_7435>[23505343] := algebra.selectNotNil(X_31=nil); | | 4 | X_33=<tmpr_7435>[23505343] := bat.reverse(X_32=nil); | | 23833624 | X_34=<tmp_7174>[5941581] := algebra.kunique(X_33=nil); | | 14 | X_35=<tmpr_7174>[5941581] := bat.reverse(X_34=nil); | | 87995 | X_36 := aggr.count(X_35=nil); | | 25 | sql.exportValue(1,"sys.f_sorted","L10":str,"wrd",64,0,6,X_36=5941581:wrd,""); | | 27306480 | X_5:void := user.s8_1("201110"); | +----------+--------------------------------------------------------------------------------------------------------------+ 29 tuples (27.3s)
Stefan Manegold wrote:
Could you possibly also share the EXPLAIN, or even TRACE of your count(distinct uuid) query with us?
Thanks!
Stefan
On Thu, Feb 09, 2012 at 05:04:51PM -0800, zack_pcd wrote:
I am seeing the following: select count(*) from f_sorted; +-----------+ | L7 | +===========+ | 102612097 | +-----------+ 1 tuple (0.988ms)
select count(*) from f_sorted where yyyymm='201110'; +----------+ | L10 | +==========+ | 23505343 | +----------+ 1 tuple (1.0s)
select count(distinct uuid) from f_sorted where yyyymm='201110'; +---------+ | L6 | +=========+ | 5941581 | +---------+ 1 tuple (23.8s)
Very fast thus far! However:
copy (select distinct(uuid) from f_sorted where yyyymm='201110') into '/home/user/filename' USING DELIMITERS ',','\n','"' NULL as 'null';
This has been running for hours and has yet to start writing to the
file.
I get this when I explain the query:
+----------------------------------------------------------------------------------------+
| mal |
+========================================================================================+
| function user.s5_3{autoCommit=true}():void; | | X_2 := sql.mvc(); | | X_22:bat[:oid,:str] :=
sql.bind(X_2,"sys","f_sorted","yyyymm",0);
| | X_23 := algebra.uselect(X_22,"201110":str); | | X_20:bat[:oid,:str] :=
sql.bind(X_2,"sys","f_sorted","yyyymm",2);
| | X_24 := algebra.kdifference(X_23,X_20); | | X_21 := algebra.uselect(X_20,"201110":str); | | X_25 := algebra.kunion(X_24,X_21); | | X_18:bat[:oid,:str] :=
sql.bind(X_2,"sys","f_sorted","yyyymm",1);
| | X_19 := algebra.uselect(X_18,"201110":str); | | X_26 := algebra.kunion(X_25,X_19); | | X_16:bat[:oid,:oid] := sql.bind_dbat(X_2,"sys","f_sorted",1); | | X_17 := bat.reverse(X_16); | | X_27 := algebra.kdifference(X_26,X_17); | | X_28 := algebra.markT(X_27,0@0:oid); | | X_29 := bat.reverse(X_28); | | X_10:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",0); | | X_8:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",2); | | X_12 := algebra.kdifference(X_10,X_8); | | X_13 := algebra.kunion(X_12,X_8); | | X_5:bat[:oid,:str] := sql.bind(X_2,"sys","f_sorted","uuid",1); | | X_14 := algebra.kunion(X_13,X_5); | | X_30 := algebra.leftjoin(X_29,X_14); | | (ext44,grp42) := group.done(X_30); | | X_33 := bat.mirror(ext44); | | X_34 := algebra.leftjoin(X_33,X_30); | | X_35 := sql.resultSet(1,1,X_34); | |
sql.rsColumn(X_35,"sys.f_sorted","uuid":str,"varchar",2048,0,X_34);
| | X_43 := io.stdout(); | | sql.exportResult(X_43,X_35); | | end s5_3; |
+----------------------------------------------------------------------------------------+
31 tuples (1.350ms)
Is it doing something wrong? I don't expect the query to take so long (hours) to produce the output, especially since the distinct count is also very fast.
The copy-into *seems* to be irrelevant to the problem, but I decided
to
include it just in case, as that's how I am using the query.
View this message in context:
http://old.nabble.com/select-distinct-...-where-algorithm-tp33297578p3329757...
Sent from the monetdb-users mailing list archive at Nabble.com.
Virtualization & Cloud Management Using Capacity Planning Cloud computing makes use of virtualization - but cloud computing also focuses on allowing computing to be delivered as a service. http://www.accelacomm.com/jaw/sfnl/114/51521223/ _______________________________________________ MonetDB-users mailing list MonetDB-users@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/monetdb-users
-- | Stefan.Manegold @ CWI.nl | DB Architectures (INS1) | | http://CWI.nl/~manegold/ | Science Park 123 (L321) | | Tel.: +31 (0)20 592-4212 | 1098 XG Amsterdam (NL) |
Virtualization & Cloud Management Using Capacity Planning Cloud computing makes use of virtualization - but cloud computing also focuses on allowing computing to be delivered as a service. http://www.accelacomm.com/jaw/sfnl/114/51521223/ _______________________________________________ MonetDB-users mailing list MonetDB-users@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/monetdb-users
-- View this message in context: http://old.nabble.com/select-distinct-...-where-algorithm-tp33297578p3330212... Sent from the monetdb-users mailing list archive at Nabble.com.
Virtualization & Cloud Management Using Capacity Planning Cloud computing makes use of virtualization - but cloud computing also focuses on allowing computing to be delivered as a service. http://www.accelacomm.com/jaw/sfnl/114/51521223/ _______________________________________________ MonetDB-users mailing list MonetDB-users@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/monetdb-users
-- Niels Nes, Centrum Wiskunde & Informatica (CWI) Science Park 123, 1098 XG Amsterdam, The Netherlands room L3.14, phone ++31 20 592-4098 sip:4098@sip.cwi.nl url: http://www.cwi.nl/~niels e-mail: Niels.Nes@cwi.nl
Virtualization & Cloud Management Using Capacity Planning Cloud computing makes use of virtualization - but cloud computing also focuses on allowing computing to be delivered as a service. http://www.accelacomm.com/jaw/sfnl/114/51521223/ _______________________________________________ MonetDB-users mailing list MonetDB-users@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/monetdb-users
participants (4)
-
Martin Kersten -
Niels Nes -
Stefan Manegold -
zack_pcd