group.mal

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

#line 81 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/group.mx"
module group;

command new(b:bat[:any_1,:any_2], start:int, incr:int, grpsize:int)
			:bat[:any_1,:int] 
address GRPgroup0
comment "Produces a new BAT with identical head column, and in the tail 
		column groups of equally valued integers within each group. 
		Parameters: a start group -value, -number increment, -size.";

command new(attr:bat[:any_1,:any_2] )
	(histo:bat[:any_1,:int], grp:bat[:any_1,:void]) 
address GRPgroup;

command new(attr:bat[:any_1,:any_2] )
	(histo:bat[:any_1,:int], grp:bat[:any_1,:oid]) 
address GRPgroup;

command new(attr:bat[:any_1,:any_2], N:int, rng:int)
	(histo:bat[:any_1,:int],grp:bat[:any_1,:oid]) 
address GRPgroup_custom
comment "Cross tabulation group initialization like GRPgroup, but with 
		user provided #bits in hashmask and #distinct values in range.";

command derive(hist:bat[:any_1,:int], map:bat[:any_1,:oid], attr:bat[:any_1,:any_2])
	(histo:bat[:any_1,:int],grp:bat[:any_1,:oid]) 
address GRPderive
comment "Cross tabulation group extension step.  Returned head values are 
		identical as in 'ct'. Tail values are from the same domain and 
		indicate further refinement of the groups in 'ct', taking into 
		account also the tail-values in 'attr'.";
command derive(histo:bat[:void,:int], map:bat[:void,:oid], attr:bat[:oid,:any_2])
	(hist:bat[:oid,:int],grp:bat[:oid,:oid]) 
address GRPderive;

command refine(b:bat[:any_2,:any_3], a:bat[:any_2,:any_1]) :bat[:any_2,:oid] 
address GRPrefine
comment "refine the ordering of a tail-ordered BAT by sub-ordering on the 
		values of a second bat 'a' (where the heads of a and b match 1-1).
		The effect of this is similar to (hash-based) GRPderive, with the 
		distinction that the group ids respect the ordering of the group 
		values.";

command refine(b:bat[:oid,:any_3], a:bat[:void,:any_1]) :bat[:oid,:oid] 
address GRPrefine;
command refine(b:bat[:void,:any_3], a:bat[:oid,:any_1]) :bat[:oid,:oid] 
address GRPrefine;

command refine_reverse(b:bat[:any_2,:any_3], a:bat[:any_2,:any_1]) :bat[:any_2,:oid] 
address GRPrefine_rev
comment "refine the ordering of a tail-ordered BAT by sub-ordering on the 
		values of a second bat 'a' (where the heads of a and b match 1-1).
		The effect of this is similar to (hash-based) GRPderive, with the 
		distinction that the group ids respect the ordering of the group 
		values.";


#line 171 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/group.mx"
	
#line 146 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/group.mx"
command sum(b:bat[:any_2,:sht], e:bat[:any_2,:any_1]) :bat[:any_2,:sht] 
address GRPsum_sht
comment "grouped tail sum";

command sum(b:bat[:any_2,:sht], size:int) :bat[:any_2,:sht] 
address GRPwindowsum_sht
comment "Tail sum of groups of a fixed size";

command sum(b:bat[:any_2,:sht], size:int, shift:int) :bat[:any_2,:sht] 
address GRPslidingsum_sht
comment "Tail sum of groups of a sliding window of fixed size";

command avg(b:bat[:any_2,:sht], e:bat[:any_2,:any_1]) :bat[:any_2,:sht] 
address GRPavg_sht
comment "grouped tail average";



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

	
#line 146 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/group.mx"
command sum(b:bat[:any_2,:int], e:bat[:any_2,:any_1]) :bat[:any_2,:int] 
address GRPsum_int
comment "grouped tail sum";

command sum(b:bat[:any_2,:int], size:int) :bat[:any_2,:int] 
address GRPwindowsum_int
comment "Tail sum of groups of a fixed size";

command sum(b:bat[:any_2,:int], size:int, shift:int) :bat[:any_2,:int] 
address GRPslidingsum_int
comment "Tail sum of groups of a sliding window of fixed size";

command avg(b:bat[:any_2,:int], e:bat[:any_2,:any_1]) :bat[:any_2,:int] 
address GRPavg_int
comment "grouped tail average";



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

	
#line 146 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/group.mx"
command sum(b:bat[:any_2,:lng], e:bat[:any_2,:any_1]) :bat[:any_2,:lng] 
address GRPsum_lng
comment "grouped tail sum";

command sum(b:bat[:any_2,:lng], size:int) :bat[:any_2,:lng] 
address GRPwindowsum_lng
comment "Tail sum of groups of a fixed size";

command sum(b:bat[:any_2,:lng], size:int, shift:int) :bat[:any_2,:lng] 
address GRPslidingsum_lng
comment "Tail sum of groups of a sliding window of fixed size";

command avg(b:bat[:any_2,:lng], e:bat[:any_2,:any_1]) :bat[:any_2,:lng] 
address GRPavg_lng
comment "grouped tail average";



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

	
#line 146 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/group.mx"
command sum(b:bat[:any_2,:flt], e:bat[:any_2,:any_1]) :bat[:any_2,:flt] 
address GRPsum_flt
comment "grouped tail sum";

command sum(b:bat[:any_2,:flt], size:int) :bat[:any_2,:flt] 
address GRPwindowsum_flt
comment "Tail sum of groups of a fixed size";

command sum(b:bat[:any_2,:flt], size:int, shift:int) :bat[:any_2,:flt] 
address GRPslidingsum_flt
comment "Tail sum of groups of a sliding window of fixed size";

command avg(b:bat[:any_2,:flt], e:bat[:any_2,:any_1]) :bat[:any_2,:flt] 
address GRPavg_flt
comment "grouped tail average";



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

	
#line 146 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/group.mx"
command sum(b:bat[:any_2,:dbl], e:bat[:any_2,:any_1]) :bat[:any_2,:dbl] 
address GRPsum_dbl
comment "grouped tail sum";

command sum(b:bat[:any_2,:dbl], size:int) :bat[:any_2,:dbl] 
address GRPwindowsum_dbl
comment "Tail sum of groups of a fixed size";

command sum(b:bat[:any_2,:dbl], size:int, shift:int) :bat[:any_2,:dbl] 
address GRPslidingsum_dbl
comment "Tail sum of groups of a sliding window of fixed size";

command avg(b:bat[:any_2,:dbl], e:bat[:any_2,:any_1]) :bat[:any_2,:dbl] 
address GRPavg_dbl
comment "grouped tail average";



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


command min(b:bat[:any_2,:any_1], e:bat[:any_2,:any_3]) :bat[:any_2,:any_1] 
address GRPmin
comment "Grouped tail minimum";
command max(b:bat[:any_2,:any_1], e:bat[:any_2,:any_3]) :bat[:any_2,:any_1] 
address GRPmax
comment "Grouped tail maximum";

command count(b:bat[:any_2,:any_1], e:bat[:any_2,:any_3], nonils:bit) :bat[:any_2,:int] 
address GRPaggr_count
comment "Grouped count";
command size(b:bat[:any_2,:bit], e:bat[:any_2,:any_1]) :bat[:any_2,:int] 
address GRPsize
comment "Grouped count of true values";



#line 207 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/group.mx"
 
#line 198 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/group.mx"
command min(b:bat[:oid,:oid]):bat[:oid,:oid]
address GRPmin_oid_oid
comment "Select the minimum element of each group";

command max(b:bat[:oid,:oid]):bat[:oid,:oid]
address GRPmax_oid_oid
comment "Select the minimum element of each group";



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

 
#line 198 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/group.mx"
command min(b:bat[:oid,:sht]):bat[:oid,:sht]
address GRPmin_oid_sht
comment "Select the minimum element of each group";

command max(b:bat[:oid,:sht]):bat[:oid,:sht]
address GRPmax_oid_sht
comment "Select the minimum element of each group";



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

 
#line 198 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/group.mx"
command min(b:bat[:oid,:int]):bat[:oid,:int]
address GRPmin_oid_int
comment "Select the minimum element of each group";

command max(b:bat[:oid,:int]):bat[:oid,:int]
address GRPmax_oid_int
comment "Select the minimum element of each group";



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

 
#line 198 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/group.mx"
command min(b:bat[:oid,:lng]):bat[:oid,:lng]
address GRPmin_oid_lng
comment "Select the minimum element of each group";

command max(b:bat[:oid,:lng]):bat[:oid,:lng]
address GRPmax_oid_lng
comment "Select the minimum element of each group";



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

 
#line 198 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/group.mx"
command min(b:bat[:oid,:flt]):bat[:oid,:flt]
address GRPmin_oid_flt
comment "Select the minimum element of each group";

command max(b:bat[:oid,:flt]):bat[:oid,:flt]
address GRPmax_oid_flt
comment "Select the minimum element of each group";



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

 
#line 198 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/group.mx"
command min(b:bat[:oid,:dbl]):bat[:oid,:dbl]
address GRPmin_oid_dbl
comment "Select the minimum element of each group";

command max(b:bat[:oid,:dbl]):bat[:oid,:dbl]
address GRPmax_oid_dbl
comment "Select the minimum element of each group";



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


command prelude()
address GRPprelude;

group.prelude();