algebra.mal

一个内存数据库的源代码这是服务器端还有客户端

	or: 'sunion(left,right).sunique'.";


#line 382 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"
command kunion ( left:bat[:any_1,:any_2], right:bat[:any_1,:any_2])
		:bat[:any_1,:any_2] 
address ALGkunion
comment "Returns the union of two BATs; looking at head-columns only. 
		Results in all BUNs of 'left' that are  not in 'right', plus 
	all BUNs of 'right'.  *no* double-elimination is done. 
		If you want this, do:
	'kunion(left.kunique,right.kunique)' 
	or: 'sunion(left,right).kunique'.";


#line 396 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"
command crossproduct(left:bat[:any_1,:any_2], right:bat[:any_3,:any_4])
	:bat[:any_1,:any_4]
address ALGcross
comment "Returns the cross product";

command antijoin(left:bat[:any_1,:any_2], right:bat[:any_2,:any_4])
	:bat[:any_1,:any_4]
address ALGantijoin
comment "Returns the antijoin";

command join( left:bat[:any_1,:any_2], right:bat[:any_2,:any_3])
		:bat[:any_1,:any_3] 
address ALGjoin
comment "Returns all BUNs, consisting of a head-value from 'left' and 
		a tail-value from 'right' for which there are BUNs in 'left' 
		and 'right' with equal tail- resp. head-value (i.e. the join
	columns are projected out).";

command join( left:bat[:any_1,:any_2], right:bat[:any_2,:any_3])
		:bat[:any_1,:any_3] 
address ALGjoin;

command leftjoin( left:bat[:any_1,:any_2], right:bat[:any_2,:any_3],
		estimate:lng) :bat[:any_1,:any_3] 
address ALGleftjoinestimate;
command join( left:bat[:any_1,:any_2], right:bat[:any_2,:any_3],
		estimate:lng) :bat[:any_1,:any_3] 
address ALGjoinestimate;

command fetchjoin ( left:bat[:any_1,:oid], right:bat[:oid,:any_3] )
		:bat[:any_1,:any_3] 
address ALGfetchjoin
comment "Hook directly into the fetch implementation of the join.";

command leftfetchjoin ( left:bat[:any_1,:oid], right:bat[:oid,:any_3] )
		:bat[:any_1,:any_3] 
address ALGleftfetchjoin
comment "Hook directly into the left fetch join implementation.";

command mergejoin (left:bat[:any_1,:any_2], right:bat[:any_2,:any_3])
		:bat[:any_1,:any_3] 
address ALGmergejoin
comment "Hook directly into the merge implementation of the join.";

command hashjoin ( left:bat[:any_1,:any_2], right:bat[:any_2,:any_3])
		:bat[:any_1,:any_3] 
address ALGhashjoin
comment "Hook directly into the hash implementation of the join.";

command indexjoin ( left:bat[:any_1,:any_2], right:bat[:any_2,:any_3])
		:bat[:any_1,:any_3] 
address ALGindexjoin
comment "Hook directly into the index implementation of the join.";



#line 452 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"
command outerjoin( outer:bat[:any_1,:any_2], inner:bat[:any_2,:any_3]) 
		:bat[:any_1,:any_3] 
address ALGouterjoin
comment "Returns all the result of a join, plus the BUNS formed NIL in 
		the tail and the head-values of 'outer' whose tail-value does 
		not match an head-value in 'inner'.";
command outerjoin( outer:bat[:any_1,:oid], inner:bat[:oid,:any_3]) 
		:bat[:any_1,:any_3] 
address ALGouterjoin
comment "Returns all the result of a join, plus the BUNS formed NIL in 
		the tail and the head-values of 'outer' whose tail-value does 
		not match an head-value in 'inner'.";
command outerjoin( outer:bat[:any_1,:oid], inner:bat[:oid,:any_3]) 
		:bat[:any_1,:any_3] 
address ALGouterjoin
comment "Returns all the result of a join, plus the BUNS formed NIL in 
		the tail and the head-values of 'outer' whose tail-value does 
		not match an head-value in 'inner'.";

command outerjoin( outer:bat[:any_1,:any_2], inner:bat[:any_2,:any_3],
		estimate:lng) :bat[:any_1,:any_3] 
address ALGouterjoinestimate;



#line 477 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"
command thetajoin( left:bat[:any_1,:any_2], right:bat[:any_2,:any_3],
		opname:int) :bat[:any_1,:any_3] 
address ALGthetajoin
comment "Theta join on for 'mode' in { LE, LT, EQ, GT, GE }.  JOIN_EQ is 
		just the same as join(). All other options do merge algorithms. 
		Either using the fact that they are ordered() already (left on tail, 
	right on head), or by using/creating binary search trees on the 
		join columns. ";

command thetajoin( left:bat[:any_1,:any_2], right:bat[:any_2,:any_3],
		opname:int,estimate:lng) :bat[:any_1,:any_3] 
address ALGthetajoinEstimate;


#line 491 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"
command bandjoin( outer:bat[:any_1,:any_2], inner:bat[:any_2,:any_3],
		   minus:any_2 , plus:any_2 ) :bat[:any_1,:any_3] 
address ALGbandjoin
comment "This is a join() for which the predicate is that two BUNs match 
		if the left-tail value is within the range [right-head - minus, 
		right-head + plus]. Works only for the builtin numerical types, 
		and their derivates.";


#line 500 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"
command project(b:bat[:any_1,:any_2]) :bat[:any_1,:oid]
address ALGprojectNIL
comment "Extract the head of a BAT.";



#line 512 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"
	
#line 505 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"
command project(v:bit,b:bat[:any_2,:any_1]) :bat[:bit,:any_1] 
address ALGprojecthead_bit
comment "Fill the head with a constant, e.g. [0~b]";
command project(b:bat[:any_2,:any_1],v:bit) :bat[:any_2,:bit] 
address ALGprojecttail_bit
comment "Fill the tail with a constant, e.g. [0~b]";


#line 512 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"

	
#line 505 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"
command project(v:chr,b:bat[:any_2,:any_1]) :bat[:chr,:any_1] 
address ALGprojecthead_chr
comment "Fill the head with a constant, e.g. [0~b]";
command project(b:bat[:any_2,:any_1],v:chr) :bat[:any_2,:chr] 
address ALGprojecttail_chr
comment "Fill the tail with a constant, e.g. [0~b]";


#line 513 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"

	
#line 505 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"
command project(v:str,b:bat[:any_2,:any_1]) :bat[:str,:any_1] 
address ALGprojecthead_str
comment "Fill the head with a constant, e.g. [0~b]";
command project(b:bat[:any_2,:any_1],v:str) :bat[:any_2,:str] 
address ALGprojecttail_str
comment "Fill the tail with a constant, e.g. [0~b]";


#line 514 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"

	
#line 505 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"
command project(v:oid,b:bat[:any_2,:any_1]) :bat[:oid,:any_1] 
address ALGprojecthead_oid
comment "Fill the head with a constant, e.g. [0~b]";
command project(b:bat[:any_2,:any_1],v:oid) :bat[:any_2,:oid] 
address ALGprojecttail_oid
comment "Fill the tail with a constant, e.g. [0~b]";


#line 515 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"

	
#line 505 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"
command project(v:int,b:bat[:any_2,:any_1]) :bat[:int,:any_1] 
address ALGprojecthead_int
comment "Fill the head with a constant, e.g. [0~b]";
command project(b:bat[:any_2,:any_1],v:int) :bat[:any_2,:int] 
address ALGprojecttail_int
comment "Fill the tail with a constant, e.g. [0~b]";


#line 516 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"

	
#line 505 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"
command project(v:sht,b:bat[:any_2,:any_1]) :bat[:sht,:any_1] 
address ALGprojecthead_sht
comment "Fill the head with a constant, e.g. [0~b]";
command project(b:bat[:any_2,:any_1],v:sht) :bat[:any_2,:sht] 
address ALGprojecttail_sht
comment "Fill the tail with a constant, e.g. [0~b]";


#line 517 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"

	
#line 505 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"
command project(v:lng,b:bat[:any_2,:any_1]) :bat[:lng,:any_1] 
address ALGprojecthead_lng
comment "Fill the head with a constant, e.g. [0~b]";
command project(b:bat[:any_2,:any_1],v:lng) :bat[:any_2,:lng] 
address ALGprojecttail_lng
comment "Fill the tail with a constant, e.g. [0~b]";


#line 518 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"

	
#line 505 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"
command project(v:flt,b:bat[:any_2,:any_1]) :bat[:flt,:any_1] 
address ALGprojecthead_flt
comment "Fill the head with a constant, e.g. [0~b]";
command project(b:bat[:any_2,:any_1],v:flt) :bat[:any_2,:flt] 
address ALGprojecttail_flt
comment "Fill the tail with a constant, e.g. [0~b]";


#line 519 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"

	
#line 505 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"
command project(v:dbl,b:bat[:any_2,:any_1]) :bat[:dbl,:any_1] 
address ALGprojecthead_dbl
comment "Fill the head with a constant, e.g. [0~b]";
command project(b:bat[:any_2,:any_1],v:dbl) :bat[:any_2,:dbl] 
address ALGprojecttail_dbl
comment "Fill the tail with a constant, e.g. [0~b]";


#line 520 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"



#line 526 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"
command markT( b:bat[:any_1,:any_2], base:oid ) :bat[:any_1,:oid] 
address ALGtmark
comment "Produces a BAT with fresh unique dense sequense of OIDs in 
		the tail that starts at base (i.e. [base,..base+b.count()-1] ).";

command markT( b:bat[:any_1,:any_2] ) :bat[:any_1,:oid] 
address ALGtmark_default
comment "Produces a BAT with fresh unique OIDs in the tail starting at 0@0.";


command markH( b:bat[:any_1,:any_2] ) :bat[:oid,:any_2] 
address ALGmarkHead_default
comment "Produces a BAT with fresh OIDs in the head starting at 0@0.";

command markH( b:bat[:any_1,:any_2], base:oid ) :bat[:oid,:any_2] 
address ALGmarkHead
comment "Produces a new BAT with fresh unique dense sequense of OIDs in 
		the head that starts at base (i.e. [base,..base+b.count()-1] ).";

command number( b:bat[:any_1,:any] ) :bat[:any_1,:int]  
address ALGnumber
comment "Produces a new BAT with identical head column, and consecutively 
		increasing integers (start at 0) in the tail column.";

command merge(b:bat[:oid,:oid]):bat[:lng,:oid]
address ALGmerge
comment "Merge head and tail into a single value";

command split(b:bat[:lng,:oid]):bat[:oid,:oid]
address ALGsplit
comment "Split head into two values";



#line 564 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"
command materialize(b:bat[:oid,:any_1]):bat[:oid,:any_1]
address ALGmaterialize
comment "Materialize the void column";

command reuse(b:bat[:any_1,:any_2]):bat[:any_1,:any_2]
address ALGreuse
comment "Reuse a temporary BAT if you can. Otherwise,
	allocate enough storage to accept result of an
 	operation (not involving the heap)";



#line 578 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/algebra.mx"
command hashsplit( b:bat[:any_1,:any_2], buckects:int ) 
		:bat[:int,:bat] 
address ALGhashsplit
comment "Split a BAT on tail column according (hash-value MOD buckets). 
		Returns a recursive BAT, containing the fragments in the tail, 
		their bucket number in the head.";

command uhashsplit ( b:bat[:any_1,:any_2], buckets:int ) :bat[:int,:bat] 
address ALGuhashsplit
comment "Same as hashsplit, but only collect the head values in the fragments";