group()

阅读(3373) 标签: group,

本章介绍group()函数的多种用法。

A.group(x i ,…)

描述:

xi,…做等值分组。

语法:

A.group(xi,…) 

备注:

将序列A按照表达式xi,…等值分组,结果为组集构成的序列/排列。

选项:

@o

只和相邻对比,相当于归并,结果集不再排序。

@1

取每个分组的第一条记录,组成排列后返回(注意是数字1,不是字母l),可以与@v配合使用。

@n

x取值为分组序号,可直接定位;与@o互斥;将x<1的数据组丢弃。

@u

结果集不再按x排序;与@o/@n互斥。

@i

x是布尔表达式,如果x的结果为true则开始新的一组。相当于A.group@o(a+=if(x,1,0))a=0且只有一个x

@0

x的计算结果为空的组丢弃,当只有一个x时可以用该选项,与@n一起使用时,也将空组丢弃。

@s

分组后序列/排列和列,相当于A.group(xi,…).conj(),可以与@v配合使用。

@p

返回组成员在A中位置构成的数列的序列。

@h

用于分段有序的数据,可提高分组效率。

@v

A为纯序表时,返回成纯序表构成的集合。

参数:

A

序列。

xi

分组表达式。

返回值:

序列/排列

示例:

Ø  对数列分组

 

A

 

1

[6,9,12,15,16,5,1,7,8]

 

2

=A1.group(~%2)

[[6,12,16,8],[ 9,15,5,1,7]]数列被分为2组,一组成员除以2余数为0,另一组成员除以2余数为1

3

=A1.group(~%2,~%3)

[[6,12],[16],[8],[9,15],[1,7],[5]]按照多个表达式分组。

4

=[6,9,16,5,1,7,8].group@s(~%2)

按照奇偶数分组后和列:

5

=A1.group((#-1)\3)

对序列A1分组,每3个一组:

Ø  对分组结果重复利用

 

A

 

1

=demo.query("select NAME,BIRTHDAY,GENDER from EMPLOYEE")

 

2

=A1.group(GENDER)

A1序表根据GENDER分组:

点开分组后每个成员就是一个序列。

3

=A2.new(GENDER:Gender,~.count():Number)

对分组后的成员统计。

4

=A2.new(GENDER:Gender,~.avg(age(BIRTHDAY)):Average)

对分组结果重复利用,再次进行不同的统计。

Ø  多种分组方式

 

A

 

1

=demo.query("select NAME,GENDER,DEPT,BIRTHDAY from EMPLOYEE")

 

2

=A1.group(GENDER,DEPT)

多字段分组。

3

=A1.group@o(GENDER)

不排序,相邻的记录比较,相同的记录归为一组。不相邻但相同的记录可能变成两组,因此会出现重复的组,返回序列集。

4

=A1.group@1(GENDER)

返回每组第一条记录:

5

=A1.group@n(if(GENDER=="F",1,2))

x取值为分组序号,可直接定位

[[Rebecca,Ashley,Rachel,…],[Matthew,Ryan,Jacob,…]]

6

=A1.group@u(GENDER,DEPT)

结果集不按分组字段排序。

7

=A1.group@i(GENDER=="F")

遇到GENDER=="F"则开始新的分组。

8

=A1.group@p(GENDER,DEPT)

返回按照字段GENDER,DEPT分组后,记录在原序表中的位置构成的序列。

9

=file("D:\\Salesman.txt").import@t()

10

=A9.group@0(Gender)

按照字段Gender分组,为空的组丢弃不显示。

11

=file("D:/emp10.txt").import@t()

数据文件emp10.txt中,每10条数据根据DEPT进行了一次排序:

12

=A11.group@h(DEPT)

A11是以DEPT分段有序的数据,使用@h选项提高分组效率:

13

=A1.group@n(if(DEPT=="HR":1,DEPT=="Sales":2;0))

使用@n选项,函数参数值小于1的数据丢弃,即将DEPT不为HR也不是Sales的数据组丢弃:

Ø  A为序表

 

A

 

1

=demo.query@v("select * from EMPLOYEE order by GENDER,DEPT ")

返回纯序表。

2

=A1.group@v(GENDER,DEPT)

使用@v选项,返回纯序表构成的集合。

 

相关概念:

A.id()

A.group(x:F,…;y:G,…)

A.group(x:F,...;y:G,…)

描述:

对序列先分组再聚合。

语法:

A.group(x:F,...;y:G,…) 

备注:

将序列按照一个或多个字段/表达式分组,然后再聚合。按照x分组后,形成以F,... G,…为字段的新序表。新序表按分组表达式x排序,G字段值为对每一组执行聚合函数y后的结果。

选项:

@o

只和相邻对比,相当于归并,结果集不再排序。

@n

x取值为分组序号,可直接定位;与@o互斥。

@u

结果集不再按x排序;与@o/@n互斥。

@i

x是布尔表达式,如果x的结果为true则开始新的一组。此时只有一个x

@0

x的计算结果为空的组丢弃。

@h

用于分段有序的数据,可提高分组效率。

@t

A的返回值为空,则返回一个保留数据结构的空序表。

@s

以累计方式计算。

参数:

A

序列。

x

分组表达式,x:F省略则不分组针对全集聚合,此时分号不可省略。

F

结果序表的字段名。

G

结果序表中的汇总字段名。

y

聚合表达式,用~引用组。

返回值:

序列

示例:

 

A

 

1

=demo.query("select * from SCORES")

 

2

=A1.group(STUDENTID:StudentID;~.sum(SCORE):TotalScore)

3

=A1.group@o(STUDENTID:StudentID;~.sum(SCORE):TotalScore)

只和相邻的对比归并,结果集不排序。

4

=demo.query("select * from STOCKRECORDS where STOCKID<'002242'")

 

5

=A4.group@n(if(STOCKID=="000062",1,2):StockID;~.sum(CLOSING):TotalPrice)

x取值为分组序号。

6

=A1.group(;~.sum(SCORE):TotalScore)

省略x:F求所有学生的总成绩。

7

=demo.query("select * from EMPLOYEE")

 

8

=A7.group@u(STATE:State;~.count(STATE):TotalScore)

结果集不按分组字段排序。

9

=A7.group@i((GENDER=="F"):IsF;~.count():Number)

遇到GENDER=="F"则开始新的分组。

10

=file("D:\\Salesman.txt").import@t()

11

=A10.group@0(Gender:Gender;~.sum(Age):Total)

Gender为空的组丢弃。

12

=file("D:/emp10.txt").import@t()

数据文件emp10.txt中,每10条数据根据DEPT进行了一次排序:

13

=A12.group@h(DEPT:dept;~.sum(SALARY):bouns)

A12是以DEPT分段有序的数据,使用@h选项提高分组效率:

14

=demo.query("select * from EMPLOYEE where EID > 500")

返回空序表。

15

=A14.group@t(STATE:State;~.count(STATE):TotalScore)

返回保留数据结构的空序表:

16

=demo.query("select * from employee").group@s(DEPT;sum(SALARY):TotleSalary)

以累计方式计算:

相关概念:

A.id()

A.group(xi,…)

ch.group()

描述:

管道中附加相邻值分组动作后返回原管道。

语法:

ch.group(x,…)

备注:

管道ch附加计算,ch按照x分组,x只和相邻的记录对比,相当于归并,要求ch有序,返回原管道。

该函数属于附加计算动作

选项:

@i

x是布尔表达式,如果x的结果为true则开始新的一组。此时只有一个x

@1

取每组的第一条记录组成排列返回到原管道(注意是数字1,不是字母l)。

参数:

ch

管道。

x

分组表达式。

返回值:

管道

示例:

 

A

 

1

=demo.cursor("select EID,GENDER,DEPT,NAME,SALARY from EMPLOYEE").sortx(GENDER,DEPT)

返回游标,游标中的数据对GENDER,DEPT有序。

2

=channel()

创建管道。

3

=A2.group(GENDER,DEPT)

A2管道附加计算,按照GENDER,DEPT分组。

4

=A2.fetch()

A2管道执行结果集函数,保留管道当前数据。

5

=A1.push(A2)

将游标A1中的数据推送到管道A2,此时数据不会立即被推送到管道。

6

=A1.skip()

A1游标执行取数动作,此时数据才会被推送到管道,然后管道执行计算并记录结果。

7

=A2.result()

获取管道计算结果:

 

 

A

 

1

=demo.cursor("select EID,GENDER,DEPT,NAME,SALARY from EMPLOYEE").sortx(DEPT)

返回游标,游标中的数据对DEPT有序。

2

=channel()

创建管道。

3

=channel()

创建管道。

4

=A2.group@1(DEPT)

管道A2附加计算,按照DEPT分组,使用@1选项,取每组的第一条记录组成排列,返回原管道A2

5

=A2.fetch()

A2管道执行结果集函数,保留管道当前数据。

6

=A3.group@i(DEPT=="HR")

管道A3附加计算,按照DEPT分组,使用@i选项,遇到DEPT ==" HR "则开始新的分组,返回原管道A3

7

=A3.fetch()

A3管道执行结果集函数,保留管道当前数据。

8

=A1.push(A2,A3)

将游标A1中的数据推送到管道A2A3,此时数据不会立即被推送到管道。

9

=A1.skip()

A1游标执行取数动作,此时数据才会被推送到管道,然后管道执行计算并记录结果。

10

=A2.result()

获取A2管道计算结果:

11

=A3.result()

获取A3管道计算结果:

cs.group()

描述:

游标中附加相邻值分组动作后返回原游标。

语法:

cs.group(x,…)

备注:

游标cs附加计算,cs按照x分组,x只和相邻的记录对比,相当于归并,要求cs有序,返回原游标cs支持多路游标

该函数属于延迟计算函数。

选项:

@i

x是布尔表达式,如果x的结果为true则开始新的一组。此时只有一个x

@1

取每组的第一条记录组成排列返回到原游标(注意是数字1,不是字母l)。

@v

cs是纯序表游标时,每组子集将复制成新的纯序表。

参数:

cs

游标/多路游标。

x

分组表达式。

返回值:

游标

示例:

 

A

 

1

=demo.cursor("select * from EMPLOYEE").sortx(GENDER,DEPT)

返回游标,游标中的数据对GENDERDEPT有序。

2

=A1.group(GENDER,DEPT)

游标A1附加计算,相邻记录中GENDERDEPT字段值都相同时,记录分到同一组中,返回A1游标。

3

=A1.fetch()

读取游标A1执行A2计算后的数据(数据量较大时建议分批读取):

  使用@i选项: 

 

A

 

1

=demo.cursor("select * from STOCKRECORDS where STOCKID='000062' ").sortx(DATE)

返回游标,游标中的数据对DATE有序。

2

=A1.group@i(CLOSING<CLOSING[-1])

游标A1附加计算,使用@i选项,当记录中的CLOSING值小于上一条记录中的CLOSING值时,开始新的一组,返回A1游标。

3

=A1.fetch()

读取游标A1执行A2计算后的数据:

使用@1选项: 

 

A

 

1

=demo.cursor("select EID,NAME,DEPT,HIREDATE from EMPLOYEE").sortx(DEPT,HIREDATE)

返回游标,游标中的数据对DEPTHIREDATE有序。

2

=A1.group@1 (DEPT)

游标A1附加计算,使用@1选项,游标记录根据DEPT分组,取每组的第一条记录返回A1游标。

3

=A1.fetch()

读取游标A1执行A2计算后的数据:

cs为纯序表游标:

 

A

 

1

=demo.cursor@v("select * from EMPLOYEE order by GENDER,DEPT ")

返回纯序表游标。

2

=A1.group@v(GENDER,DEPT)

游标A1附加计算,使用@v选项,每组子集将复制成新的纯序表,返回原游标。

3

=A1.()

获取A1游标执行A2计算后的分组数。

 

相关概念:

A.group(xi,…)

A.group(x:F,…;y:G,…)

cs.group()

描述:

针对集群游标记录做相邻值分组。

语法:

cs.group(x,…)

备注:

针对集群游标记录cs按照x分组,x只和相邻的记录对比,相当于归并,要求cs有序,返回由序列构成的原集群游标,支持多路游标

参数:

cs

集群游标记录。

x

分组表达式,多个字段/表达式组合分组时,每个分组表达式用逗号隔开。

返回值:

原集群游标

示例:

 

A

 

1

=file("employees.ctx","192.168.0.111:8281")

employees.ctx文件对DEPT有序,数据内容如下:

2

=A1.open()

打开集群组表。

3

=A2.cursor()

返回集群游标。

4

=A3.group(DEPT)

将集群游标记录根据DEPT分组,结果返回原集群游标。

5

=A4.fetch()

 

cs.group(x:F,…;y:G,…)

描述:

游标中附加相邻值分组聚合动作后返回原游标。

语法:

cs.group(x:F,...;y:G,…)

备注:

游标cs附加计算,cs根据x分组后计算聚合表达式yx为字段F的值y为字段G的值, 形成以F,... G,为字段的序表返回到原游标cs。支持多路游标。

csx有序,x只和相邻的记录对比,结果集不再排序。

该函数属于延迟计算函数。

参数:

cs

游标。

x

分组表达式。

F

字段名。

G

汇总字段名。

y

聚合表达式。

选项:

@s

用累积方式聚合。

@q(x:F,…;x’:F’,…; y:G,…)

cs已对x,…有序,仅后面的字段需要排序时可用该选项,可以内存排序。

@sq(x:F,…;x’:F’,…; y:G,…)

没有y:G参数时仅排序,不分组;有y:G参数时按累计方式聚合。该用法中@s必须与@q配合使用。

@e

y的结果组成的序表返回到原游标。其中xcs的字段名,ycs的函数,y的计算结果要求是cs的一条记录,当y是聚合函数时仅支持maxp/minp/top@1

组合使用@sev选项时,返回结果为纯序表。

返回值:

游标

示例:

 

A

 

1

=demo.cursor("select * from SCORES").sortx(CLASS,STUDENTID)

返回游标,游标内容对CLASS,STUDENTID有序,数据内容如下:

2

=A1.group(CLASS:Class,STUDENTID:StudentID;~.sum(SCORE):TotalScore)

游标A1附加计算,根据CLASS,STUDENTID相邻值分组,汇总每组的SCORE值,汇总结果作为TotalScore字段值,返回原游标cs

3

=A1.fetch()

读取游标A1执行A2计算后的数据:

使用@q选项:

 

A

 

1

=demo.cursor("select EID,NAME,DEPT,GENDER,SALARY from EMPLOYEE ").sortx(DEPT)

返回游标,游标内容对DEPT有序,数据内容如下:

2

=A1.group@q(DEPT;GENDER;~.avg(SALARY):Avg_Salary)

游标A1附加计算,游标对DEPT有序,仅GENDER字段需要排序,使用@q选项进行内存排序,返回原游标cs

3

=A1.fetch()

读取游标A1执行A2计算后的数据:

  使用@sq选项,无需汇总仅排序时: 

 

A

 

1

=demo.cursor("select EID,NAME,DEPT,GENDER,SALARY from EMPLOYEE ").sortx(DEPT)

返回游标,游标内容对DEPT有序,数据内容如下:

2

=A1.group@sq(DEPT;GENDER)

游标A1附加计算,游标仅对DEPT有序,且省略汇总聚合参数,使用@sq选项仅排序不分组,返回原游标cs

3

=A1.fetch()

读取游标A1执行A2计算后的数据:

使用@e选项,将y的结果组成的序表返回到原游标:

 

A

 

1

=demo.cursor("select EID,NAME,DEPT,SALARY from EMPLOYEE  ").sortx(DEPT)

返回游标,游标内容对DEPT有序。

2

=A1.group@e(DEPT;~.maxp(SALARY))

游标A1附加计算,使用@e选项,将maxp(SALARY)结果记录返回到原游标。

3

=A1.fetch()

读取游标A1执行A2计算后的数据:

cs.group(x:F,…;y:G,…)

描述:

对集群游标做相邻分组聚合,返回原集群游标。

语法:

cs.group(x:F,...;y:G,…)

备注:

针对集群游标记录cs按照x分组,csx有序,x只和相邻的记录对比,同时计算出y,结果集不再排序。按照x分组后,形成以F,... G,…为字段的原游标。G字段值为对每一组执行聚合函数y后的结果,支持多路游标。

参数:

cs

集群游标。

x

分组表达式。

F

字段名。

G

汇总字段名。

y

聚合表达式。

返回值:

集群游标

示例:

 

A

 

1

=file("employees.ctx","192.168.0.111:8281")

employees.ctx文件对DEPT有序,数据内容如下:

2

=A1.open()

打开集群组表。

3

=A2.cursor()

返回集群游标。

4

=A3.group(DEPT:dept;count(NAME):count)

根据DEPT相邻分组,然后聚合,结果返回原集群游标。

5

=A4.fetch()

 

T. group ()

描述:

虚表定义相邻值分组操作后返回新虚表。

语法:

T.group(xi,…)

备注:

虚表T定义计算,T按照xi 分组,xi 只和相邻的记录对比,相当于归并,要求T有序,返回新虚表。

参数:

T

虚表。

xi

分组表达式,多个字段/表达式组合分组时,每个分组表达式用逗号隔开。

选项:

@i

x是布尔表达式,如果x的结果为true则开始新的一组。此时只有一个x

@1

取每一个分组的第一条记录组成排列后返回(注意是数字1,不是字母l)。

@v

组表第一次加载时用列式,提升性能。

返回值:

虚表

示例:

 

A

 

1

=create(file).record(["D:/file/pseudo/empT.ctx"])

 

2

=pseudo(A1)

生成虚表对象,虚表数据内容如下:

3

=A2.group(GENDER,DEPT)

虚表A2定义计算,相邻记录中GENDERDEPT字段值皆相同时,记录分到同一组中,结果返回新虚表。

4

=A3.import()

读取A3虚表中的数据,此时A2虚表执行A3中定义的计算操作,返回内容如下:

5

=A2.group@i(GENDER=="F")

使用@i选项,遇到GENDER=="F"则开始新的分组。

6

=A5.import()

读取A5虚表数据:

 

7

=A2.group@1(GENDER)

使用@1选项,返回每组第一条记录。

8

=A7.cursor().fetch()

读取A7虚表数据:

T.group(x:F,…;y:G,…)

描述:

虚表中定义相邻分组聚合操作后返回新虚表。

语法:

T.group(x:F,...;y:G,…) 

备注:

虚表T定义计算,T根据x分组后计算聚合表达式yx为字段F的值,y为字段G的值, 形成以F,... G,…为字段的新虚表,

Tx有序,x只和相邻的记录对比,结果集不再排序。

参数:

T

虚表。

x

分组表达式。

F

字段名。

G

汇总字段名。

y

聚合表达式。

选项:

@s

用累积方式聚合。

@q(x:F,…;x’:F’,…;…)

T已对x,…有序,仅后面的字段需要排序时可用该选项,可以内存排序。

@sq(x:F,…;x’:F’,…;…)

没有y:G参数时仅排序,不分组;有y:G参数时按累计方式聚合。该用法中@s必须与@q配合使用。

@e

返回y的结果组成的虚表。其中xT的字段名,yT的函数,y的计算结果要求是T的一条记录,当y是聚合函数时仅支持maxp/minp/top@1

返回值:

虚表

示例:

 

A

 

1

=create(file).record(["scores-g.ctx"])

scores-g.ctx 为对STUDENTID有序的组表文件,内容如下:

2

=pseudo(A1)

A1组表生成虚表。

3

=A2.group(STUDENTID:StudentID;~.sum(SCORE):TotalScore)

虚表A2定义计算,将虚表根据STUDENTID字段分组,并计算每组的SCORE的总值,结果返回新虚表。

4

=A3.import()

读取A3虚表中的数据,此时A2虚表执行A3中定义的计算操作,返回内容如下:

 

 

A

 

1

=create(file).record(["emp-g.ctx"])

emp-g.ctx为对DEPT有序的组表文件,内容如下:

2

=pseudo(A1)

A1组表产生虚表。

3

=A2.group@q(DEPT;GENDER)

虚表A2定义计算,虚表已经对DEPT有序,所以分组时仅对GENDER排序,返回新虚表。

4

=A3.cursor().fetch()

读取A3虚表中的数据,此时A2虚表执行A3中定义的计算操作,返回内容如下:

5

=A2.group@qs(DEPT:DEPT;GENDER:GENDER)

虚表A2定义计算,没有y:G参数时仅排序,不分组,返回新虚表。

6

=A5.import()

读取A5虚表中的数据,此时A2虚表执行A5中定义的计算操作,返回内容如下:

7

=A2.group@qs(DEPT:DEPT;GENDER:GENDER;count(GENDER):count)

虚表A2定义计算,有y:G参数,按累计方式聚合,返回新虚表。

8

=A7.import()

读取A7虚表中的数据,此时A2虚表执行A7中定义的计算操作,返回内容如下:

使用@e选项,返回y的结果组成的虚表:

 

A

 

1

=create(file).record(["emp-g.ctx"])

组表emp-g.ctx中的内容如下:

2

=pseudo(A1)

A1组表产生虚表。

3

=A2.group@e(DEPT;~.minp(SALARY))

虚表A2定义计算,使用@e选项,返回由minp(SALARY)结果记录构成的新虚表。

4

=A3.fetch().cursor()

读取A3虚表中的数据,此时A2虚表执行A3中定义的计算操作,返回内容如下: