本文介绍的SPL排序优化技巧，除了提供常规的排序算法外，还根据不同场景下的数据特性提供了排序的替代算法，从而减少比较次数和IO量，提升运算性能。
1内存排序
当数据可以轻松装入内存时，可以使用SPL的内存排序函数，如A.sort()。SPL默认的排序算法是基于merge sort的多线程排序算法，也就是说，此时的优化方式主要是通过增加线程数量实现的。实际采用的线程数由集算器配置中的[最大并行数]指定。示例代码如下：
|
A |
B |
|
|
1 |
=5000*1000 |
/元素数 |
|
2 |
=A1\1000 |
/随机数最大值 |
|
3 |
=to(A1).(rand(A2)) |
/生成随机序列 |
|
4 |
=now() |
/当前时间 |
|
5 |
=A3.sort() |
/升序排序 |
|
6 |
=interval@ms(A4,now()) |
/排序花费的时间 |
实测使用的的测试机CPU是酷睿i7 ，4核心 8线程，根据 [最大并行数]配置的不同，测试结果如下：
|
最大并行数 |
平均花费时间（毫秒） |
|
1（即单线程） |
1800 |
|
4 |
800 |
|
8 |
660 |
可见，多核心CPU或多CPU计算机通过多线程排序可以充分利用每个核心的并行计算能力，显著提升排序性能。
此例中每个值的重复量平均为1000，对A.sort()函数来说，重复数量的多少对性能影响不大。但在重复数量较多时，我们还可以通过分组法A.group@s()进行排序，进一步提高性能。此方法首先利用哈希法对元素进行分组，然后再对组进行排序，最后合并排序后的组得到排序结果。示例代码如下：
|
A |
B |
|
|
1 |
=5000*1000 |
/元素数 |
|
2 |
=A1\1000 |
/随机数最大值 |
|
3 |
=to(A1).(rand(A2)) |
/生成随机序列 |
|
4 |
=now() |
/当前时间 |
|
5 |
=A3.group@s() |
/每个值平均有1000个重复的，使用分组法进行升序排序 |
|
6 |
=interval@ms(A4,now()) |
/排序花费的时间 |
使用分组法排序后，平均花费时间为360毫秒，可见，此方法适合重复数量较多的数据，重复数量越多性能越好。
2外存排序
当数据量大到无法装入内存时就需要借助外存进行排序。外存排序会分步读入数据，排序后写出到临时文件，最后对所有生成的临时文件归并得到最终结果。
临时文件的数量会影响排序的效率，如果数量过多，归并阶段会占用更多的资源，而归并路数过多也会影响归并效率。所以每次读入较多的数据量可以提升sortx的性能。
SPL外存排序的函数是cs.sortx()，排序中生成的临时文件数量由原始数据量和每次读入的数据量决定，而每次读入的数据量可以通过sortx函数的参数指定。用户可以根据记录大小和空闲内存容量指定一个合理的每次读入数据量以达到最优的性能。如果没有指定，SPL会根据虚拟机可用内存估算出一个大概值。
临时文件的释放会在结果游标取数结束或者close方法被调用时触发。
测试外存排序需要大数据量，而由于使用JDBC从数据库取数的效率非常差，因此本文将采用效率更好的集文件进行测试。
测试数据模拟订单数据，表结构为{ order_id ,order_datetime , customer_id, employee_id , product_id , quantity ,price}，按order_id 、order_datetime有序，随机生成2000万条记录。
测试数据的生成也使用SPL，造数代码如下：
|
A |
B |
|
|
1 |
2018-01-01 00:00:00 |
=file("orders_2018.btx") |
|
2 |
=to(1000*1000) |
0 |
|
3 |
for 20 |
=A2.new(B2+~:order_id, elapse@s(A1,order_id):order_datetime, rand(1000000) + 1:customer_id, rand(1000) + 1:employee_id, rand(10000) + 1:product_id, rand(1000) + 1:quantity, rand(100000000)/100:price) |
|
4 |
=B1.export@ab(B3) |
|
|
5 |
>B2=B2+A2.len() |
排序计算的代码如下：
|
A |
B |
|
|
1 |
=now() |
|
|
2 |
=file("orders_2018.btx").cursor@b() |
/生成订单集文件的取数游标 |
|
3 |
=A2.sortx(customer_id; 2000000) |
/对游标按客户编码排序，第二个参数为每次读入的数据量 |
|
4 |
=file("orders_customer_2018.btx").export@b(A3) |
/导出排序结果到集文件 |
|
5 |
=interval@s(A1,now()) |
/耗时，单位秒 |
测试结果如下：
|
每次读入数据量 |
耗时（秒） |
|
200万 |
73 |
|
20万 |
216 |
3多路归并
使用SPL处理大数据运算时，为了获取更好的性能通常会把数据外置成集文件或组表，同时按照常用的过滤维度排序以获得更高的过滤性能。这样，如果有新的数据要追加到历史文件，并需要对所有数据重新排序，我们就可以利用集文件或者组表的这个特点了。由于历史数据已经有序，此时我们可以先把新数据按照维度排序，然后再和历史数据进行归并就可以得到最终的有序数据了。使用这个方法排序涉及的数据量远小于对所有数据进行大排序的数据量。具体的测试如下：
在前面外存排序的造数代码中，将A1格改为2017-01-01 00:00:00，B1格改为=file("orders_2017.btx")，生成模拟2017年的订单数据文件“orders_2017.btx”。然后使用外存排序代码按customer_id字段排序，生成排序结果文件“orders_2017_customer.btx”。
然后，我们需要将2017、2018两年的所有数据进行整体排序，也就是使用归并方法合并orders_2017_customer.btx、orders_2018_customer.btx两个文件成一个新的有序文件。示例代码如下：
|
A |
B |
|
|
1 |
=now() |
|
|
2 |
=file("orders_2017_customer.btx").cursor@b() |
|
|
3 |
=file("orders_2018_customer.btx").cursor@b() |
|
|
4 |
=[A2,A3].mergex(customer_id) |
/对两个按customer_id有序的游标做归并，合成一个按customer_id有序的新游标 |
|
5 |
=file("orders1.btx").export@b(A4) |
/把排序后的数据导出到集文件 |
|
6 |
=now() |
=interval@s(A1,A6) |
|
7 |
=file("orders_2017_customer.btx").cursor@b() |
|
|
8 |
=file("orders_2018_customer.btx").cursor@b() |
|
|
9 |
=[A7,A8].conjx().sortx(customer_id; 2000000) |
/纵向连接两个游标并进行外存排序 |
|
10 |
=file("orders2.btx").export@b(A9) |
|
|
11 |
=now() |
=interval@s(A6,A11) |
前6行代码采用了归并方法，耗时30秒，而后5行代码模拟了简单的大排序方法，耗时133秒。
4前半有序
如果需要按照多个字段对数据进行排序，而数据已经按照排序字段中的几个字段有序了，则可以按照已经有序的字段分组读入数据，在内存排序后输出。这种处理方法比cs.sortx()少了一遍读写操作，因此性能大幅优于cs.sortx()。
例如订单表的数据是按照日期时间有序生成的，如果想按照日期、客户两个字段对订单表进行排序则可以使用这个方法。示例代码如下：
|
A |
B |
|
|
1 |
=now() |
|
|
2 |
=file("orders_2017.btx").cursor@b() |
|
|
3 |
=A2.run(order_datetime=date(order_datetime)) |
/把日期时间转为日期类型 |
|
4 |
=A2.group@qs(order_datetime;customer_id) |
/数据已按order_datetime有序，对数据按order_datetime,customer_id排序 |
|
5 |
=file("orders_2017_date_customer.btx").export@b(A4) |
|
|
6 |
=interval@s(A1,now()) |
经测试耗时为38秒（A6格的值），而如果把A4格表达式替换为下面代码则耗时95秒。
|
A |
B |
|
|
4 |
=A2.sortx(order_datetime,customer_id;2000000) |
/数据已按order_datetime有序，对数据按order_datetime,customer_id排序 |
5索引排序
SPL的组表提供了为某些列创建索引的功能，一些常用的列也可以存到索引里，这样如果访问的列都在索引里就不需要再访问整个源文件，从而节省大量IO操作。而如果排序字段是索引字段，并且需要访问的字段也都在索引里，则可以利用索引的有序性，使用T.icursor@s()返回有序游标。
创建索引的代码如下：
|
A |
B |
|
|
1 |
2018-01-01 00:00:00 |
=file("orders.ctx") |
|
2 |
=to(1000*1000) |
0 |
|
3 |
=B1.create@y(#order_id,#order_datetime,customer_id,employee_id,product_id,quantity, price) |
|
|
4 |
/以下循环为创建组表数据程序 |
|
|
5 |
for 20 |
=A2.new(B2+~:order_id, elapse@s(A1,order_id):order_datetime, rand(1000000) + 1:customer_id, rand(1000) + 1:employee_id, rand(10000) + 1:product_id, rand(1000) + 1:quantity, rand(100000000)/100:price) |
|
6 |
=A3.append(B5.cursor()) |
|
|
7 |
>B2=B2+A2.len() |
|
|
8 |
=A3.index(PriceIndex;price;product_id,order_datetime) |
/按金额字段建索引，同时保持产品,日期两个字段的值 |
利用索引产生有序游标代码如下：
|
A |
B |
|
|
1 |
=now() |
=file("orders.ctx").create() |
|
2 |
=B1.icursor@s(order_datetime,product_id,price;true,PriceIndex) |
/利用索引返回有序游标 |
|
3 |
for A2,10000 |
/遍历游标数据 |
|
4 |
=now() |
=interval@ms(A1,A4) |
|
5 |
=B1.cursor(order_datetime,product_id,price) |
|
|
6 |
=A5.sortx(price) |
/外存排序 |
|
7 |
for A6,10000 |
/遍历游标数据 |
|
8 |
=now() |
=interval@ms(A4,A8) |
经测试有序游标耗时为4秒（B4格的值），而外存排序遍历耗时为54秒（B8格的值）。