You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by yi...@apache.org on 2022/07/18 08:35:22 UTC
[doris] branch master updated: [regression] Add ssb sf1 test under unique table with zstd (#10957)
This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 216a55c12c [regression] Add ssb sf1 test under unique table with zstd (#10957)
216a55c12c is described below
commit 216a55c12c0be5c4090523195b2aff9d96c64f65
Author: Hong Liu <84...@qq.com>
AuthorDate: Mon Jul 18 16:35:14 2022 +0800
[regression] Add ssb sf1 test under unique table with zstd (#10957)
* Add ssb sf1 test under unique table with zstd
Co-authored-by: smallhibiscus <844981280>
---
.../data/ssb_sf1_unique_sql_zstd/sql/q1.1.out | 4 +
.../data/ssb_sf1_unique_sql_zstd/sql/q1.2.out | 4 +
.../data/ssb_sf1_unique_sql_zstd/sql/q1.3.out | 4 +
.../data/ssb_sf1_unique_sql_zstd/sql/q2.1.out | 283 +++++++++
.../data/ssb_sf1_unique_sql_zstd/sql/q2.2.out | 59 ++
.../data/ssb_sf1_unique_sql_zstd/sql/q2.3.out | 10 +
.../data/ssb_sf1_unique_sql_zstd/sql/q3.1.out | 153 +++++
.../data/ssb_sf1_unique_sql_zstd/sql/q3.2.out | 602 ++++++++++++++++++
.../data/ssb_sf1_unique_sql_zstd/sql/q3.3.out | 27 +
.../data/ssb_sf1_unique_sql_zstd/sql/q3.4.out | 6 +
.../data/ssb_sf1_unique_sql_zstd/sql/q4.1.out | 38 ++
.../data/ssb_sf1_unique_sql_zstd/sql/q4.2.out | 103 +++
.../data/ssb_sf1_unique_sql_zstd/sql/q4.3.out | 697 +++++++++++++++++++++
.../ddl/customer_create.sql | 16 +
.../ddl/customer_delete.sql | 1 +
.../ddl/customer_part_delete.sql | 1 +
.../ddl/customer_sequence_create.sql | 17 +
.../ssb_sf1_unique_load_zstd/ddl/date_create.sql | 25 +
.../ssb_sf1_unique_load_zstd/ddl/date_delete.sql | 1 +
.../ddl/date_part_delete.sql | 1 +
.../ddl/date_sequence_create.sql | 26 +
.../ddl/lineorder_create.sql | 33 +
.../ddl/lineorder_delete.sql | 1 +
.../ddl/lineorder_part_delete.sql | 1 +
.../ddl/lineorder_sequence_create.sql | 34 +
.../ssb_sf1_unique_load_zstd/ddl/part_create.sql | 17 +
.../ssb_sf1_unique_load_zstd/ddl/part_delete.sql | 1 +
.../ddl/part_part_delete.sql | 1 +
.../ddl/part_sequence_create.sql | 18 +
.../ddl/supplier_create.sql | 15 +
.../ddl/supplier_delete.sql | 1 +
.../ddl/supplier_part_delete.sql | 1 +
.../ddl/supplier_sequence_create.sql | 16 +
.../ssb_sf1_unique_load_zstd/load_four_step.groovy | 112 ++++
.../ssb_sf1_unique_load_zstd/load_one_step.groovy | 68 ++
.../load_three_step.groovy | 77 +++
.../ssb_sf1_unique_load_zstd/load_two_step.groovy | 75 +++
.../ddl/customer_create.sql | 16 +
.../ddl/customer_delete.sql | 1 +
.../ssb_sf1_unique_sql_zstd/ddl/date_create.sql | 25 +
.../ssb_sf1_unique_sql_zstd/ddl/date_delete.sql | 1 +
.../ddl/lineorder_create.sql | 33 +
.../ddl/lineorder_delete.sql | 1 +
.../ssb_sf1_unique_sql_zstd/ddl/part_create.sql | 17 +
.../ssb_sf1_unique_sql_zstd/ddl/part_delete.sql | 1 +
.../ddl/supplier_create.sql | 15 +
.../ddl/supplier_delete.sql | 1 +
.../suites/ssb_sf1_unique_sql_zstd/load.groovy | 86 +++
.../suites/ssb_sf1_unique_sql_zstd/sql/q1.1.sql | 24 +
.../suites/ssb_sf1_unique_sql_zstd/sql/q1.2.sql | 24 +
.../suites/ssb_sf1_unique_sql_zstd/sql/q1.3.sql | 25 +
.../suites/ssb_sf1_unique_sql_zstd/sql/q2.1.sql | 26 +
.../suites/ssb_sf1_unique_sql_zstd/sql/q2.2.sql | 27 +
.../suites/ssb_sf1_unique_sql_zstd/sql/q2.3.sql | 26 +
.../suites/ssb_sf1_unique_sql_zstd/sql/q3.1.sql | 28 +
.../suites/ssb_sf1_unique_sql_zstd/sql/q3.2.sql | 28 +
.../suites/ssb_sf1_unique_sql_zstd/sql/q3.3.sql | 30 +
.../suites/ssb_sf1_unique_sql_zstd/sql/q3.4.sql | 30 +
.../suites/ssb_sf1_unique_sql_zstd/sql/q4.1.sql | 30 +
.../suites/ssb_sf1_unique_sql_zstd/sql/q4.2.sql | 31 +
.../suites/ssb_sf1_unique_sql_zstd/sql/q4.3.sql | 29 +
61 files changed, 3104 insertions(+)
diff --git a/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q1.1.out b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q1.1.out
new file mode 100644
index 0000000000..ba450f16d5
--- /dev/null
+++ b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q1.1.out
@@ -0,0 +1,4 @@
+-- This file is automatically generated. You should know what you did if you want to edit this
+-- !q1.1 --
+446031203850
+
diff --git a/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q1.2.out b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q1.2.out
new file mode 100644
index 0000000000..9e6e59831d
--- /dev/null
+++ b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q1.2.out
@@ -0,0 +1,4 @@
+-- This file is automatically generated. You should know what you did if you want to edit this
+-- !q1.2 --
+98714004603
+
diff --git a/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q1.3.out b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q1.3.out
new file mode 100644
index 0000000000..dd5cabbd7c
--- /dev/null
+++ b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q1.3.out
@@ -0,0 +1,4 @@
+-- This file is automatically generated. You should know what you did if you want to edit this
+-- !q1.3 --
+26232701005
+
diff --git a/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q2.1.out b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q2.1.out
new file mode 100644
index 0000000000..e1ebddab41
--- /dev/null
+++ b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q2.1.out
@@ -0,0 +1,283 @@
+-- This file is automatically generated. You should know what you did if you want to edit this
+-- !q2.1 --
+567838207 1992 MFGR#121
+610663790 1992 MFGR#1210
+550769662 1992 MFGR#1211
+649205856 1992 MFGR#1212
+624031241 1992 MFGR#1213
+670488468 1992 MFGR#1214
+633152470 1992 MFGR#1215
+674846781 1992 MFGR#1216
+675093435 1992 MFGR#1217
+600202070 1992 MFGR#1218
+538043594 1992 MFGR#1219
+655326672 1992 MFGR#122
+540262882 1992 MFGR#1220
+556120633 1992 MFGR#1221
+590762777 1992 MFGR#1222
+535448651 1992 MFGR#1223
+703752611 1992 MFGR#1224
+570832868 1992 MFGR#1225
+614061593 1992 MFGR#1226
+581759388 1992 MFGR#1227
+644642592 1992 MFGR#1228
+640858430 1992 MFGR#1229
+789755835 1992 MFGR#123
+468535087 1992 MFGR#1230
+592436656 1992 MFGR#1231
+664275152 1992 MFGR#1232
+613885100 1992 MFGR#1233
+667399281 1992 MFGR#1234
+640290070 1992 MFGR#1235
+501892561 1992 MFGR#1236
+591481503 1992 MFGR#1237
+477423770 1992 MFGR#1238
+638259374 1992 MFGR#1239
+572354196 1992 MFGR#124
+740479248 1992 MFGR#1240
+478777095 1992 MFGR#125
+592174616 1992 MFGR#126
+706151632 1992 MFGR#127
+542306646 1992 MFGR#128
+581987352 1992 MFGR#129
+823087702 1993 MFGR#121
+648160706 1993 MFGR#1210
+634743898 1993 MFGR#1211
+785639283 1993 MFGR#1212
+638255029 1993 MFGR#1213
+616837237 1993 MFGR#1214
+634687975 1993 MFGR#1215
+638353900 1993 MFGR#1216
+663372951 1993 MFGR#1217
+683985855 1993 MFGR#1218
+646950033 1993 MFGR#1219
+622532984 1993 MFGR#122
+530830127 1993 MFGR#1220
+543346337 1993 MFGR#1221
+756921203 1993 MFGR#1222
+533544350 1993 MFGR#1223
+915916085 1993 MFGR#1224
+473007381 1993 MFGR#1225
+739036124 1993 MFGR#1226
+592178887 1993 MFGR#1227
+583507058 1993 MFGR#1228
+617453491 1993 MFGR#1229
+637863868 1993 MFGR#123
+625534310 1993 MFGR#1230
+580327635 1993 MFGR#1231
+697373098 1993 MFGR#1232
+515571416 1993 MFGR#1233
+651935758 1993 MFGR#1234
+575779480 1993 MFGR#1235
+591878667 1993 MFGR#1236
+609618576 1993 MFGR#1237
+444614010 1993 MFGR#1238
+595256327 1993 MFGR#1239
+660586237 1993 MFGR#124
+788730059 1993 MFGR#1240
+616224539 1993 MFGR#125
+617126754 1993 MFGR#126
+654438324 1993 MFGR#127
+731657001 1993 MFGR#128
+548048395 1993 MFGR#129
+564405648 1994 MFGR#121
+645404849 1994 MFGR#1210
+631620635 1994 MFGR#1211
+568332348 1994 MFGR#1212
+678785857 1994 MFGR#1213
+534002330 1994 MFGR#1214
+654400242 1994 MFGR#1215
+558646341 1994 MFGR#1216
+687845641 1994 MFGR#1217
+546674347 1994 MFGR#1218
+567272942 1994 MFGR#1219
+659884062 1994 MFGR#122
+562582172 1994 MFGR#1220
+598618997 1994 MFGR#1221
+601016441 1994 MFGR#1222
+555134404 1994 MFGR#1223
+737422302 1994 MFGR#1224
+570745955 1994 MFGR#1225
+746302245 1994 MFGR#1226
+651707481 1994 MFGR#1227
+573693547 1994 MFGR#1228
+647918373 1994 MFGR#1229
+580449592 1994 MFGR#123
+493270412 1994 MFGR#1230
+603546148 1994 MFGR#1231
+719865331 1994 MFGR#1232
+638982238 1994 MFGR#1233
+743247677 1994 MFGR#1234
+598680959 1994 MFGR#1235
+615726097 1994 MFGR#1236
+542569815 1994 MFGR#1237
+573510781 1994 MFGR#1238
+579855853 1994 MFGR#1239
+684573322 1994 MFGR#124
+873735737 1994 MFGR#1240
+560488304 1994 MFGR#125
+657036514 1994 MFGR#126
+622571183 1994 MFGR#127
+586845664 1994 MFGR#128
+534541525 1994 MFGR#129
+706469511 1995 MFGR#121
+602892803 1995 MFGR#1210
+645166092 1995 MFGR#1211
+613289283 1995 MFGR#1212
+599586479 1995 MFGR#1213
+562570804 1995 MFGR#1214
+672528755 1995 MFGR#1215
+669000972 1995 MFGR#1216
+725362449 1995 MFGR#1217
+657026635 1995 MFGR#1218
+519659003 1995 MFGR#1219
+724727741 1995 MFGR#122
+517956131 1995 MFGR#1220
+635741351 1995 MFGR#1221
+564368410 1995 MFGR#1222
+600665149 1995 MFGR#1223
+762700351 1995 MFGR#1224
+671669586 1995 MFGR#1225
+572568748 1995 MFGR#1226
+530361300 1995 MFGR#1227
+633357085 1995 MFGR#1228
+547960244 1995 MFGR#1229
+660711077 1995 MFGR#123
+602735858 1995 MFGR#1230
+499852146 1995 MFGR#1231
+715300753 1995 MFGR#1232
+557149571 1995 MFGR#1233
+710023059 1995 MFGR#1234
+622425239 1995 MFGR#1235
+634565501 1995 MFGR#1236
+572847270 1995 MFGR#1237
+549318912 1995 MFGR#1238
+593851712 1995 MFGR#1239
+585421815 1995 MFGR#124
+707207888 1995 MFGR#1240
+538246872 1995 MFGR#125
+605799021 1995 MFGR#126
+665978112 1995 MFGR#127
+646960956 1995 MFGR#128
+508749401 1995 MFGR#129
+523879145 1996 MFGR#121
+643645053 1996 MFGR#1210
+595065339 1996 MFGR#1211
+674626440 1996 MFGR#1212
+496297087 1996 MFGR#1213
+583249505 1996 MFGR#1214
+702184857 1996 MFGR#1215
+601809334 1996 MFGR#1216
+704898387 1996 MFGR#1217
+528843086 1996 MFGR#1218
+586246330 1996 MFGR#1219
+712110492 1996 MFGR#122
+518444215 1996 MFGR#1220
+499319414 1996 MFGR#1221
+679469356 1996 MFGR#1222
+628762754 1996 MFGR#1223
+724844856 1996 MFGR#1224
+660620587 1996 MFGR#1225
+667674729 1996 MFGR#1226
+483838085 1996 MFGR#1227
+609855391 1996 MFGR#1228
+658959557 1996 MFGR#1229
+566217852 1996 MFGR#123
+528879998 1996 MFGR#1230
+589481194 1996 MFGR#1231
+702805896 1996 MFGR#1232
+663679947 1996 MFGR#1233
+571149450 1996 MFGR#1234
+478648074 1996 MFGR#1235
+568249365 1996 MFGR#1236
+592616167 1996 MFGR#1237
+466676148 1996 MFGR#1238
+670693719 1996 MFGR#1239
+560667719 1996 MFGR#124
+821167950 1996 MFGR#1240
+476864333 1996 MFGR#125
+558030884 1996 MFGR#126
+635873891 1996 MFGR#127
+551010618 1996 MFGR#128
+560570630 1996 MFGR#129
+587013207 1997 MFGR#121
+616287892 1997 MFGR#1210
+548588761 1997 MFGR#1211
+589593892 1997 MFGR#1212
+424306670 1997 MFGR#1213
+511971910 1997 MFGR#1214
+631772246 1997 MFGR#1215
+692135140 1997 MFGR#1216
+777994957 1997 MFGR#1217
+707053720 1997 MFGR#1218
+561169527 1997 MFGR#1219
+664916245 1997 MFGR#122
+594466157 1997 MFGR#1220
+588848171 1997 MFGR#1221
+528988960 1997 MFGR#1222
+537098211 1997 MFGR#1223
+674763166 1997 MFGR#1224
+450402292 1997 MFGR#1225
+701360722 1997 MFGR#1226
+506011570 1997 MFGR#1227
+585578737 1997 MFGR#1228
+622744016 1997 MFGR#1229
+646503168 1997 MFGR#123
+571800941 1997 MFGR#1230
+502601790 1997 MFGR#1231
+677924656 1997 MFGR#1232
+534455976 1997 MFGR#1233
+714934715 1997 MFGR#1234
+767151420 1997 MFGR#1235
+618877179 1997 MFGR#1236
+639638057 1997 MFGR#1237
+401953419 1997 MFGR#1238
+610756714 1997 MFGR#1239
+543248087 1997 MFGR#124
+675132692 1997 MFGR#1240
+479099365 1997 MFGR#125
+570696568 1997 MFGR#126
+583074592 1997 MFGR#127
+695133104 1997 MFGR#128
+655638776 1997 MFGR#129
+344575925 1998 MFGR#121
+417152416 1998 MFGR#1210
+317068168 1998 MFGR#1211
+374341516 1998 MFGR#1212
+332740903 1998 MFGR#1213
+304873002 1998 MFGR#1214
+366101132 1998 MFGR#1215
+379133898 1998 MFGR#1216
+359508497 1998 MFGR#1217
+320623334 1998 MFGR#1218
+346182862 1998 MFGR#1219
+312440027 1998 MFGR#122
+348123961 1998 MFGR#1220
+339845398 1998 MFGR#1221
+355416161 1998 MFGR#1222
+344889822 1998 MFGR#1223
+396906691 1998 MFGR#1224
+290208878 1998 MFGR#1225
+419415707 1998 MFGR#1226
+358466340 1998 MFGR#1227
+251549955 1998 MFGR#1228
+383138860 1998 MFGR#1229
+296330561 1998 MFGR#123
+437181243 1998 MFGR#1230
+398944492 1998 MFGR#1231
+424062455 1998 MFGR#1232
+406967188 1998 MFGR#1233
+428867240 1998 MFGR#1234
+352277781 1998 MFGR#1235
+361827086 1998 MFGR#1236
+341618569 1998 MFGR#1237
+244739231 1998 MFGR#1238
+414151803 1998 MFGR#1239
+330082371 1998 MFGR#124
+415312453 1998 MFGR#1240
+360289624 1998 MFGR#125
+341657580 1998 MFGR#126
+377507061 1998 MFGR#127
+361416497 1998 MFGR#128
+318769573 1998 MFGR#129
+
diff --git a/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q2.2.out b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q2.2.out
new file mode 100644
index 0000000000..8677d312f4
--- /dev/null
+++ b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q2.2.out
@@ -0,0 +1,59 @@
+-- This file is automatically generated. You should know what you did if you want to edit this
+-- !q2.2 --
+709524929 1992 MFGR#2221
+783846394 1992 MFGR#2222
+765052002 1992 MFGR#2223
+651488962 1992 MFGR#2224
+646528589 1992 MFGR#2225
+709650548 1992 MFGR#2226
+745556316 1992 MFGR#2227
+756901875 1992 MFGR#2228
+766521103 1993 MFGR#2221
+691475597 1993 MFGR#2222
+758220752 1993 MFGR#2223
+669662707 1993 MFGR#2224
+773854228 1993 MFGR#2225
+737087518 1993 MFGR#2226
+781967766 1993 MFGR#2227
+680880216 1993 MFGR#2228
+685777518 1994 MFGR#2221
+666524807 1994 MFGR#2222
+733993590 1994 MFGR#2223
+707869040 1994 MFGR#2224
+721251967 1994 MFGR#2225
+822495919 1994 MFGR#2226
+720837128 1994 MFGR#2227
+826225350 1994 MFGR#2228
+775437074 1995 MFGR#2221
+761354792 1995 MFGR#2222
+637832575 1995 MFGR#2223
+589765707 1995 MFGR#2224
+708290039 1995 MFGR#2225
+747356383 1995 MFGR#2226
+802502540 1995 MFGR#2227
+895936786 1995 MFGR#2228
+700010008 1996 MFGR#2221
+777310085 1996 MFGR#2222
+656095314 1996 MFGR#2223
+656859917 1996 MFGR#2224
+765820896 1996 MFGR#2225
+808177734 1996 MFGR#2226
+729563303 1996 MFGR#2227
+819665874 1996 MFGR#2228
+727342382 1997 MFGR#2221
+664533779 1997 MFGR#2222
+748288392 1997 MFGR#2223
+630422081 1997 MFGR#2224
+757391203 1997 MFGR#2225
+747889257 1997 MFGR#2226
+728857899 1997 MFGR#2227
+775312985 1997 MFGR#2228
+335304504 1998 MFGR#2221
+409347137 1998 MFGR#2222
+459109577 1998 MFGR#2223
+413318072 1998 MFGR#2224
+410402095 1998 MFGR#2225
+453515044 1998 MFGR#2226
+390506405 1998 MFGR#2227
+397939103 1998 MFGR#2228
+
diff --git a/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q2.3.out b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q2.3.out
new file mode 100644
index 0000000000..cb87e34504
--- /dev/null
+++ b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q2.3.out
@@ -0,0 +1,10 @@
+-- This file is automatically generated. You should know what you did if you want to edit this
+-- !q2.3 --
+726427486 1992 MFGR#2239
+705238959 1993 MFGR#2239
+664145134 1994 MFGR#2239
+713839336 1995 MFGR#2239
+728492865 1996 MFGR#2239
+733896532 1997 MFGR#2239
+380255731 1998 MFGR#2239
+
diff --git a/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q3.1.out b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q3.1.out
new file mode 100644
index 0000000000..c618f9495d
--- /dev/null
+++ b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q3.1.out
@@ -0,0 +1,153 @@
+-- This file is automatically generated. You should know what you did if you want to edit this
+-- !q3.1 --
+INDONESIA INDONESIA 1992 6905698988
+CHINA INDONESIA 1992 6616078869
+CHINA CHINA 1992 6456431477
+VIETNAM INDONESIA 1992 6340181707
+VIETNAM CHINA 1992 6332844390
+INDONESIA CHINA 1992 6310709533
+INDIA INDONESIA 1992 6238807354
+JAPAN INDONESIA 1992 6222565638
+CHINA INDIA 1992 6189831351
+CHINA JAPAN 1992 6157678893
+JAPAN CHINA 1992 6067100655
+INDIA CHINA 1992 6066461811
+VIETNAM JAPAN 1992 5863786349
+JAPAN INDIA 1992 5802749985
+INDONESIA INDIA 1992 5770203218
+VIETNAM INDIA 1992 5698511401
+INDONESIA JAPAN 1992 5663765610
+JAPAN JAPAN 1992 5648034711
+INDIA JAPAN 1992 5421959281
+CHINA VIETNAM 1992 5412322026
+JAPAN VIETNAM 1992 5401692555
+INDIA INDIA 1992 5361243755
+INDONESIA VIETNAM 1992 5302638372
+INDIA VIETNAM 1992 5245330621
+VIETNAM VIETNAM 1992 5111731778
+INDONESIA INDONESIA 1993 6931363262
+INDONESIA CHINA 1993 6612891249
+CHINA INDONESIA 1993 6581513366
+VIETNAM INDONESIA 1993 6511639352
+CHINA CHINA 1993 6444513787
+CHINA INDIA 1993 6421694121
+VIETNAM CHINA 1993 6413579999
+INDIA INDONESIA 1993 6331058594
+JAPAN CHINA 1993 6292293995
+INDIA CHINA 1993 6209353792
+CHINA JAPAN 1993 6195466884
+VIETNAM INDIA 1993 6161174477
+INDONESIA INDIA 1993 6151664306
+INDONESIA JAPAN 1993 6147605249
+JAPAN INDONESIA 1993 6053946313
+INDIA JAPAN 1993 5995208985
+CHINA VIETNAM 1993 5885023228
+VIETNAM JAPAN 1993 5874266867
+INDONESIA VIETNAM 1993 5840287722
+JAPAN INDIA 1993 5823343157
+INDIA INDIA 1993 5571575799
+VIETNAM VIETNAM 1993 5554161183
+JAPAN JAPAN 1993 5430318583
+JAPAN VIETNAM 1993 5406569653
+INDIA VIETNAM 1993 5233871487
+VIETNAM CHINA 1994 6709883442
+CHINA CHINA 1994 6648942965
+INDONESIA CHINA 1994 6483600910
+CHINA JAPAN 1994 6349037021
+VIETNAM INDONESIA 1994 6347441931
+JAPAN CHINA 1994 6320009218
+INDONESIA INDONESIA 1994 6315331086
+CHINA INDIA 1994 6297582811
+CHINA INDONESIA 1994 6234787896
+VIETNAM JAPAN 1994 6231973047
+INDONESIA INDIA 1994 6198412245
+INDIA INDONESIA 1994 6168189859
+INDONESIA JAPAN 1994 6141195969
+JAPAN INDONESIA 1994 6013034618
+CHINA VIETNAM 1994 5885318733
+INDIA CHINA 1994 5815022714
+VIETNAM INDIA 1994 5789398691
+JAPAN JAPAN 1994 5753821482
+JAPAN INDIA 1994 5645818872
+INDONESIA VIETNAM 1994 5624346368
+INDIA INDIA 1994 5584936515
+VIETNAM VIETNAM 1994 5418498159
+INDIA JAPAN 1994 5394134974
+JAPAN VIETNAM 1994 5275821637
+INDIA VIETNAM 1994 5251039815
+CHINA INDONESIA 1995 7074539444
+INDONESIA CHINA 1995 6928620620
+CHINA CHINA 1995 6624666612
+JAPAN CHINA 1995 6519889385
+VIETNAM CHINA 1995 6332731268
+INDONESIA INDONESIA 1995 6268531321
+VIETNAM JAPAN 1995 6263957020
+CHINA INDIA 1995 6246656374
+VIETNAM INDIA 1995 6198441957
+INDONESIA INDIA 1995 6173805183
+VIETNAM INDONESIA 1995 6057820148
+CHINA JAPAN 1995 6021854130
+INDONESIA JAPAN 1995 6019093871
+INDIA CHINA 1995 6010532793
+INDIA INDONESIA 1995 5975518597
+JAPAN JAPAN 1995 5952279129
+JAPAN INDONESIA 1995 5947000735
+VIETNAM VIETNAM 1995 5754727607
+JAPAN INDIA 1995 5730743126
+INDONESIA VIETNAM 1995 5574974066
+INDIA INDIA 1995 5565995550
+JAPAN VIETNAM 1995 5501313775
+CHINA VIETNAM 1995 5489936063
+INDIA JAPAN 1995 5469203427
+INDIA VIETNAM 1995 5207063284
+INDONESIA INDONESIA 1996 6750056283
+CHINA INDONESIA 1996 6657125075
+INDONESIA CHINA 1996 6613439112
+CHINA CHINA 1996 6591697915
+VIETNAM CHINA 1996 6428653890
+VIETNAM INDONESIA 1996 6295626732
+JAPAN INDONESIA 1996 6227447856
+INDIA CHINA 1996 6198567819
+INDIA INDONESIA 1996 6189242058
+CHINA INDIA 1996 6153787365
+INDONESIA INDIA 1996 6138810863
+CHINA JAPAN 1996 6105566324
+JAPAN CHINA 1996 6088985564
+INDONESIA JAPAN 1996 6055638222
+VIETNAM JAPAN 1996 5919997150
+VIETNAM VIETNAM 1996 5860842302
+INDIA JAPAN 1996 5841664805
+VIETNAM INDIA 1996 5807486983
+JAPAN INDIA 1996 5644579616
+JAPAN JAPAN 1996 5566204795
+INDIA INDIA 1996 5532073103
+INDONESIA VIETNAM 1996 5438514387
+CHINA VIETNAM 1996 5434772818
+JAPAN VIETNAM 1996 5334277549
+INDIA VIETNAM 1996 5293891531
+CHINA INDONESIA 1997 6653234696
+INDONESIA CHINA 1997 6577396314
+CHINA CHINA 1997 6463794795
+JAPAN INDONESIA 1997 6429270126
+INDONESIA INDONESIA 1997 6398427821
+VIETNAM INDONESIA 1997 6363583120
+CHINA JAPAN 1997 6284733518
+VIETNAM CHINA 1997 6164218723
+INDIA CHINA 1997 6153282214
+CHINA INDIA 1997 6084283983
+INDONESIA JAPAN 1997 6001427956
+INDIA INDONESIA 1997 5983439300
+JAPAN CHINA 1997 5973849687
+CHINA VIETNAM 1997 5908254176
+JAPAN INDIA 1997 5796921992
+JAPAN JAPAN 1997 5790450039
+INDONESIA INDIA 1997 5789367105
+VIETNAM INDIA 1997 5730121608
+INDIA INDIA 1997 5693028907
+VIETNAM JAPAN 1997 5689345230
+INDONESIA VIETNAM 1997 5665678132
+VIETNAM VIETNAM 1997 5620251324
+INDIA JAPAN 1997 5587827913
+JAPAN VIETNAM 1997 5249874614
+INDIA VIETNAM 1997 5003624837
+
diff --git a/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q3.2.out b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q3.2.out
new file mode 100644
index 0000000000..6fa0c9ba6d
--- /dev/null
+++ b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q3.2.out
@@ -0,0 +1,602 @@
+-- This file is automatically generated. You should know what you did if you want to edit this
+-- !q3.2 --
+UNITED ST4 UNITED ST1 1992 102027455
+UNITED ST1 UNITED ST0 1992 96989491
+UNITED ST7 UNITED ST0 1992 96078010
+UNITED ST9 UNITED ST0 1992 94813294
+UNITED ST4 UNITED ST0 1992 94644242
+UNITED ST2 UNITED ST4 1992 91180500
+UNITED ST5 UNITED ST0 1992 90432300
+UNITED ST6 UNITED ST7 1992 87658267
+UNITED ST3 UNITED ST9 1992 86142048
+UNITED ST6 UNITED ST5 1992 85882966
+UNITED ST7 UNITED ST3 1992 83765666
+UNITED ST2 UNITED ST9 1992 83705618
+UNITED ST4 UNITED ST6 1992 81886374
+UNITED ST2 UNITED ST1 1992 81839165
+UNITED ST9 UNITED ST1 1992 80795302
+UNITED ST6 UNITED ST3 1992 78778218
+UNITED ST6 UNITED ST0 1992 78696956
+UNITED ST0 UNITED ST1 1992 77267396
+UNITED ST0 UNITED ST0 1992 75622122
+UNITED ST1 UNITED ST9 1992 75367059
+UNITED ST3 UNITED ST1 1992 73637490
+UNITED ST2 UNITED ST0 1992 72210218
+UNITED ST1 UNITED ST7 1992 71472973
+UNITED ST6 UNITED ST4 1992 71086944
+UNITED ST4 UNITED ST4 1992 70111335
+UNITED ST6 UNITED ST1 1992 69408688
+UNITED ST4 UNITED ST3 1992 69001787
+UNITED ST5 UNITED ST7 1992 68333651
+UNITED ST4 UNITED ST9 1992 67837970
+UNITED ST7 UNITED ST6 1992 65513205
+UNITED ST4 UNITED ST5 1992 65057872
+UNITED ST7 UNITED ST4 1992 64900888
+UNITED ST1 UNITED ST1 1992 64669070
+UNITED ST3 UNITED ST5 1992 64239048
+UNITED ST0 UNITED ST9 1992 63979996
+UNITED ST3 UNITED ST4 1992 63144772
+UNITED ST5 UNITED ST6 1992 62628093
+UNITED ST4 UNITED ST7 1992 62529376
+UNITED ST3 UNITED ST0 1992 62441656
+UNITED ST9 UNITED ST4 1992 61489513
+UNITED ST8 UNITED ST6 1992 60540440
+UNITED ST7 UNITED ST9 1992 60326042
+UNITED ST7 UNITED ST7 1992 60121386
+UNITED ST5 UNITED ST1 1992 59945287
+UNITED ST5 UNITED ST4 1992 57625627
+UNITED ST7 UNITED ST5 1992 57566802
+UNITED ST2 UNITED ST5 1992 57021365
+UNITED ST9 UNITED ST7 1992 56883359
+UNITED ST0 UNITED ST3 1992 56359317
+UNITED ST1 UNITED ST3 1992 55727474
+UNITED ST5 UNITED ST3 1992 53963553
+UNITED ST0 UNITED ST7 1992 50583409
+UNITED ST5 UNITED ST9 1992 50191091
+UNITED ST7 UNITED ST1 1992 50167208
+UNITED ST0 UNITED ST8 1992 49732640
+UNITED ST0 UNITED ST4 1992 49676807
+UNITED ST9 UNITED ST3 1992 47681165
+UNITED ST8 UNITED ST4 1992 46757019
+UNITED ST3 UNITED ST3 1992 45087216
+UNITED ST8 UNITED ST0 1992 44368839
+UNITED ST0 UNITED ST6 1992 42471806
+UNITED ST6 UNITED ST8 1992 42463690
+UNITED ST8 UNITED ST7 1992 41897901
+UNITED ST3 UNITED ST8 1992 41275764
+UNITED ST6 UNITED ST9 1992 40591721
+UNITED ST0 UNITED ST5 1992 40120886
+UNITED ST1 UNITED ST4 1992 39326346
+UNITED ST3 UNITED ST7 1992 39028579
+UNITED ST3 UNITED ST6 1992 38798715
+UNITED ST9 UNITED ST9 1992 36048343
+UNITED ST2 UNITED ST8 1992 36046449
+UNITED ST2 UNITED ST3 1992 35981963
+UNITED ST8 UNITED ST1 1992 35680752
+UNITED ST1 UNITED ST6 1992 35404990
+UNITED ST8 UNITED ST5 1992 35187610
+UNITED ST1 UNITED ST5 1992 33971251
+UNITED ST5 UNITED ST8 1992 33878053
+UNITED ST2 UNITED ST7 1992 33702779
+UNITED ST8 UNITED ST3 1992 30949324
+UNITED ST8 UNITED ST8 1992 29309108
+UNITED ST5 UNITED ST5 1992 29279568
+UNITED ST1 UNITED ST8 1992 28565579
+UNITED ST9 UNITED ST5 1992 28075004
+UNITED ST2 UNITED ST6 1992 27813739
+UNITED ST0 UNITED ST2 1992 27718733
+UNITED ST2 UNITED ST2 1992 25743654
+UNITED ST8 UNITED ST9 1992 22684471
+UNITED ST4 UNITED ST8 1992 21928442
+UNITED ST9 UNITED ST8 1992 21386100
+UNITED ST5 UNITED ST2 1992 20495817
+UNITED ST6 UNITED ST6 1992 18137105
+UNITED ST9 UNITED ST6 1992 15879568
+UNITED ST4 UNITED ST2 1992 12061845
+UNITED ST7 UNITED ST8 1992 11895702
+UNITED ST6 UNITED ST2 1992 11820698
+UNITED ST9 UNITED ST2 1992 11623177
+UNITED ST8 UNITED ST2 1992 10971561
+UNITED ST1 UNITED ST2 1992 7706728
+UNITED ST7 UNITED ST2 1992 4943204
+UNITED ST3 UNITED ST2 1992 1097208
+UNITED ST0 UNITED ST9 1993 109834040
+UNITED ST7 UNITED ST0 1993 109788024
+UNITED ST5 UNITED ST0 1993 106822597
+UNITED ST0 UNITED ST0 1993 106742548
+UNITED ST1 UNITED ST0 1993 99305952
+UNITED ST4 UNITED ST4 1993 98150465
+UNITED ST3 UNITED ST4 1993 92493920
+UNITED ST0 UNITED ST1 1993 91196593
+UNITED ST4 UNITED ST1 1993 88521423
+UNITED ST8 UNITED ST0 1993 88356371
+UNITED ST4 UNITED ST7 1993 88172198
+UNITED ST4 UNITED ST0 1993 86918458
+UNITED ST6 UNITED ST3 1993 83417161
+UNITED ST6 UNITED ST1 1993 83345939
+UNITED ST7 UNITED ST9 1993 80310701
+UNITED ST3 UNITED ST1 1993 78230278
+UNITED ST6 UNITED ST7 1993 78197294
+UNITED ST5 UNITED ST9 1993 76286539
+UNITED ST0 UNITED ST3 1993 76171283
+UNITED ST5 UNITED ST8 1993 74359279
+UNITED ST9 UNITED ST1 1993 74059419
+UNITED ST4 UNITED ST9 1993 73296959
+UNITED ST5 UNITED ST1 1993 71454623
+UNITED ST6 UNITED ST4 1993 69646913
+UNITED ST2 UNITED ST1 1993 69631701
+UNITED ST6 UNITED ST0 1993 68247539
+UNITED ST7 UNITED ST7 1993 68109820
+UNITED ST2 UNITED ST3 1993 66972438
+UNITED ST3 UNITED ST0 1993 66626926
+UNITED ST9 UNITED ST7 1993 66625483
+UNITED ST1 UNITED ST8 1993 66146198
+UNITED ST2 UNITED ST7 1993 64185014
+UNITED ST5 UNITED ST4 1993 63415639
+UNITED ST9 UNITED ST9 1993 63260763
+UNITED ST1 UNITED ST4 1993 62884347
+UNITED ST7 UNITED ST4 1993 61656613
+UNITED ST3 UNITED ST6 1993 58584808
+UNITED ST2 UNITED ST4 1993 56650391
+UNITED ST3 UNITED ST5 1993 55907305
+UNITED ST6 UNITED ST9 1993 54900942
+UNITED ST1 UNITED ST7 1993 54851183
+UNITED ST3 UNITED ST9 1993 54762596
+UNITED ST8 UNITED ST6 1993 54633062
+UNITED ST8 UNITED ST3 1993 54049874
+UNITED ST5 UNITED ST7 1993 52745538
+UNITED ST0 UNITED ST5 1993 52701052
+UNITED ST1 UNITED ST9 1993 52514902
+UNITED ST8 UNITED ST5 1993 52237837
+UNITED ST1 UNITED ST3 1993 52097946
+UNITED ST8 UNITED ST4 1993 51419356
+UNITED ST0 UNITED ST6 1993 50432282
+UNITED ST5 UNITED ST5 1993 50357189
+UNITED ST3 UNITED ST7 1993 50135448
+UNITED ST0 UNITED ST4 1993 49260067
+UNITED ST0 UNITED ST7 1993 48796360
+UNITED ST2 UNITED ST9 1993 48188507
+UNITED ST1 UNITED ST1 1993 47538610
+UNITED ST9 UNITED ST3 1993 46943647
+UNITED ST7 UNITED ST5 1993 44763692
+UNITED ST1 UNITED ST6 1993 44728540
+UNITED ST8 UNITED ST1 1993 44415434
+UNITED ST7 UNITED ST8 1993 43902628
+UNITED ST9 UNITED ST6 1993 43867160
+UNITED ST2 UNITED ST0 1993 42845485
+UNITED ST3 UNITED ST8 1993 42251848
+UNITED ST0 UNITED ST8 1993 42002682
+UNITED ST4 UNITED ST8 1993 41657582
+UNITED ST1 UNITED ST5 1993 40693513
+UNITED ST9 UNITED ST5 1993 39685269
+UNITED ST7 UNITED ST3 1993 39523861
+UNITED ST8 UNITED ST8 1993 38790235
+UNITED ST8 UNITED ST9 1993 38516361
+UNITED ST2 UNITED ST5 1993 37406845
+UNITED ST9 UNITED ST8 1993 37184696
+UNITED ST8 UNITED ST7 1993 36902218
+UNITED ST6 UNITED ST8 1993 36456741
+UNITED ST7 UNITED ST1 1993 34391159
+UNITED ST6 UNITED ST5 1993 34229082
+UNITED ST5 UNITED ST3 1993 34031811
+UNITED ST2 UNITED ST8 1993 33445446
+UNITED ST4 UNITED ST3 1993 33129412
+UNITED ST6 UNITED ST6 1993 33050663
+UNITED ST9 UNITED ST0 1993 32653305
+UNITED ST4 UNITED ST6 1993 30699255
+UNITED ST9 UNITED ST4 1993 30644687
+UNITED ST4 UNITED ST5 1993 29119594
+UNITED ST7 UNITED ST6 1993 27100502
+UNITED ST4 UNITED ST2 1993 27012678
+UNITED ST2 UNITED ST6 1993 26482226
+UNITED ST5 UNITED ST6 1993 25357679
+UNITED ST3 UNITED ST3 1993 21777144
+UNITED ST3 UNITED ST2 1993 21559073
+UNITED ST5 UNITED ST2 1993 20610242
+UNITED ST7 UNITED ST2 1993 20219304
+UNITED ST6 UNITED ST2 1993 18814367
+UNITED ST9 UNITED ST2 1993 17718390
+UNITED ST1 UNITED ST2 1993 16844538
+UNITED ST0 UNITED ST2 1993 15042145
+UNITED ST2 UNITED ST2 1993 14521995
+UNITED ST8 UNITED ST2 1993 9984366
+UNITED ST8 UNITED ST0 1994 99220789
+UNITED ST3 UNITED ST9 1994 97476185
+UNITED ST6 UNITED ST1 1994 96937147
+UNITED ST6 UNITED ST9 1994 94683309
+UNITED ST9 UNITED ST1 1994 90440948
+UNITED ST0 UNITED ST9 1994 89865202
+UNITED ST5 UNITED ST7 1994 89089961
+UNITED ST9 UNITED ST0 1994 87670573
+UNITED ST3 UNITED ST1 1994 85523653
+UNITED ST4 UNITED ST9 1994 83822393
+UNITED ST0 UNITED ST0 1994 83526877
+UNITED ST7 UNITED ST0 1994 82265536
+UNITED ST2 UNITED ST1 1994 81300089
+UNITED ST5 UNITED ST0 1994 78648057
+UNITED ST4 UNITED ST7 1994 76954140
+UNITED ST4 UNITED ST4 1994 76837381
+UNITED ST0 UNITED ST1 1994 76613379
+UNITED ST1 UNITED ST3 1994 75992459
+UNITED ST7 UNITED ST1 1994 75320799
+UNITED ST4 UNITED ST0 1994 73719340
+UNITED ST5 UNITED ST1 1994 73508418
+UNITED ST4 UNITED ST1 1994 72219557
+UNITED ST2 UNITED ST9 1994 69671054
+UNITED ST6 UNITED ST5 1994 66461534
+UNITED ST2 UNITED ST3 1994 65620760
+UNITED ST3 UNITED ST0 1994 65522727
+UNITED ST5 UNITED ST3 1994 65334911
+UNITED ST7 UNITED ST4 1994 64778715
+UNITED ST3 UNITED ST4 1994 63412365
+UNITED ST8 UNITED ST4 1994 62141681
+UNITED ST0 UNITED ST4 1994 61519744
+UNITED ST0 UNITED ST7 1994 61480820
+UNITED ST0 UNITED ST6 1994 61288778
+UNITED ST2 UNITED ST0 1994 60182153
+UNITED ST6 UNITED ST4 1994 59829989
+UNITED ST4 UNITED ST5 1994 59397028
+UNITED ST8 UNITED ST9 1994 58666906
+UNITED ST4 UNITED ST6 1994 58633482
+UNITED ST5 UNITED ST5 1994 56235213
+UNITED ST6 UNITED ST3 1994 56123238
+UNITED ST2 UNITED ST4 1994 55679377
+UNITED ST8 UNITED ST3 1994 55203841
+UNITED ST1 UNITED ST1 1994 54383174
+UNITED ST1 UNITED ST7 1994 53853106
+UNITED ST6 UNITED ST0 1994 53728853
+UNITED ST5 UNITED ST9 1994 53367331
+UNITED ST9 UNITED ST9 1994 51980849
+UNITED ST5 UNITED ST4 1994 51799593
+UNITED ST7 UNITED ST9 1994 50144085
+UNITED ST7 UNITED ST7 1994 46446442
+UNITED ST6 UNITED ST6 1994 46199722
+UNITED ST7 UNITED ST5 1994 45895364
+UNITED ST3 UNITED ST3 1994 45627153
+UNITED ST8 UNITED ST5 1994 44553056
+UNITED ST9 UNITED ST4 1994 43910761
+UNITED ST1 UNITED ST0 1994 43225201
+UNITED ST1 UNITED ST9 1994 43000037
+UNITED ST7 UNITED ST8 1994 42776467
+UNITED ST0 UNITED ST5 1994 41808301
+UNITED ST2 UNITED ST6 1994 41526105
+UNITED ST1 UNITED ST4 1994 41381558
+UNITED ST3 UNITED ST7 1994 40935131
+UNITED ST8 UNITED ST1 1994 40152096
+UNITED ST9 UNITED ST8 1994 39278808
+UNITED ST5 UNITED ST6 1994 38658451
+UNITED ST2 UNITED ST5 1994 37640317
+UNITED ST8 UNITED ST7 1994 37600687
+UNITED ST9 UNITED ST5 1994 37146726
+UNITED ST6 UNITED ST7 1994 37057808
+UNITED ST8 UNITED ST6 1994 36776569
+UNITED ST3 UNITED ST6 1994 36290257
+UNITED ST9 UNITED ST3 1994 35846500
+UNITED ST2 UNITED ST8 1994 33767774
+UNITED ST0 UNITED ST8 1994 31845433
+UNITED ST4 UNITED ST3 1994 31599433
+UNITED ST9 UNITED ST7 1994 31586173
+UNITED ST1 UNITED ST6 1994 31287326
+UNITED ST1 UNITED ST8 1994 30245153
+UNITED ST7 UNITED ST3 1994 29424840
+UNITED ST9 UNITED ST6 1994 29212927
+UNITED ST0 UNITED ST3 1994 27327829
+UNITED ST6 UNITED ST8 1994 26592996
+UNITED ST3 UNITED ST5 1994 26197875
+UNITED ST6 UNITED ST2 1994 25809000
+UNITED ST1 UNITED ST5 1994 24939138
+UNITED ST7 UNITED ST6 1994 24631937
+UNITED ST1 UNITED ST2 1994 23556586
+UNITED ST4 UNITED ST2 1994 23035892
+UNITED ST2 UNITED ST7 1994 22182758
+UNITED ST0 UNITED ST2 1994 22017954
+UNITED ST4 UNITED ST8 1994 20685352
+UNITED ST7 UNITED ST2 1994 19655081
+UNITED ST5 UNITED ST8 1994 18931891
+UNITED ST2 UNITED ST2 1994 18068657
+UNITED ST3 UNITED ST8 1994 15936051
+UNITED ST8 UNITED ST8 1994 10023412
+UNITED ST3 UNITED ST2 1994 9995234
+UNITED ST9 UNITED ST2 1994 9700989
+UNITED ST5 UNITED ST2 1994 7162796
+UNITED ST8 UNITED ST2 1994 3789626
+UNITED ST5 UNITED ST1 1995 119793669
+UNITED ST4 UNITED ST9 1995 99490068
+UNITED ST7 UNITED ST0 1995 98031295
+UNITED ST6 UNITED ST0 1995 91718471
+UNITED ST4 UNITED ST1 1995 90878653
+UNITED ST0 UNITED ST1 1995 90763599
+UNITED ST8 UNITED ST9 1995 88855089
+UNITED ST7 UNITED ST7 1995 86571624
+UNITED ST3 UNITED ST0 1995 84462733
+UNITED ST9 UNITED ST1 1995 82938967
+UNITED ST2 UNITED ST4 1995 82432305
+UNITED ST1 UNITED ST0 1995 81676623
+UNITED ST5 UNITED ST4 1995 81016761
+UNITED ST7 UNITED ST1 1995 79964362
+UNITED ST5 UNITED ST3 1995 78099130
+UNITED ST5 UNITED ST0 1995 77615746
+UNITED ST9 UNITED ST9 1995 76515958
+UNITED ST7 UNITED ST9 1995 75317709
+UNITED ST4 UNITED ST4 1995 74587071
+UNITED ST9 UNITED ST4 1995 72525686
+UNITED ST1 UNITED ST9 1995 72470870
+UNITED ST4 UNITED ST7 1995 69264407
+UNITED ST6 UNITED ST3 1995 67513062
+UNITED ST2 UNITED ST3 1995 65218129
+UNITED ST2 UNITED ST9 1995 65055178
+UNITED ST7 UNITED ST6 1995 65020671
+UNITED ST3 UNITED ST1 1995 64762815
+UNITED ST1 UNITED ST1 1995 64199332
+UNITED ST6 UNITED ST9 1995 63457105
+UNITED ST0 UNITED ST9 1995 63253499
+UNITED ST5 UNITED ST9 1995 62364897
+UNITED ST4 UNITED ST5 1995 62081505
+UNITED ST1 UNITED ST7 1995 61515741
+UNITED ST2 UNITED ST7 1995 60000208
+UNITED ST8 UNITED ST6 1995 58990404
+UNITED ST1 UNITED ST4 1995 57535599
+UNITED ST0 UNITED ST3 1995 56360708
+UNITED ST8 UNITED ST0 1995 55231664
+UNITED ST5 UNITED ST7 1995 53740759
+UNITED ST2 UNITED ST0 1995 52560838
+UNITED ST3 UNITED ST7 1995 51579548
+UNITED ST9 UNITED ST0 1995 51548621
+UNITED ST6 UNITED ST6 1995 50954677
+UNITED ST5 UNITED ST5 1995 50394007
+UNITED ST7 UNITED ST4 1995 49899545
+UNITED ST3 UNITED ST3 1995 48158089
+UNITED ST6 UNITED ST4 1995 47697241
+UNITED ST9 UNITED ST7 1995 46464589
+UNITED ST4 UNITED ST0 1995 46142899
+UNITED ST1 UNITED ST3 1995 45823056
+UNITED ST2 UNITED ST1 1995 45437340
+UNITED ST6 UNITED ST5 1995 45428152
+UNITED ST8 UNITED ST5 1995 44994863
+UNITED ST7 UNITED ST3 1995 43699734
+UNITED ST9 UNITED ST6 1995 43482494
+UNITED ST2 UNITED ST5 1995 43382417
+UNITED ST6 UNITED ST8 1995 41973920
+UNITED ST0 UNITED ST6 1995 40718942
+UNITED ST3 UNITED ST5 1995 40057815
+UNITED ST7 UNITED ST5 1995 39015293
+UNITED ST0 UNITED ST0 1995 38984502
+UNITED ST6 UNITED ST1 1995 38328352
+UNITED ST4 UNITED ST6 1995 38109524
+UNITED ST3 UNITED ST9 1995 37364623
+UNITED ST4 UNITED ST3 1995 37356396
+UNITED ST2 UNITED ST6 1995 37146288
+UNITED ST9 UNITED ST5 1995 36009924
+UNITED ST1 UNITED ST8 1995 34918793
+UNITED ST8 UNITED ST1 1995 34217780
+UNITED ST0 UNITED ST7 1995 33395313
+UNITED ST1 UNITED ST5 1995 31857452
+UNITED ST8 UNITED ST7 1995 30918202
+UNITED ST2 UNITED ST8 1995 30504189
+UNITED ST3 UNITED ST4 1995 30422346
+UNITED ST5 UNITED ST6 1995 30204737
+UNITED ST8 UNITED ST3 1995 29349938
+UNITED ST0 UNITED ST4 1995 29170038
+UNITED ST1 UNITED ST6 1995 27139403
+UNITED ST7 UNITED ST8 1995 26444490
+UNITED ST6 UNITED ST7 1995 23833977
+UNITED ST4 UNITED ST8 1995 23053236
+UNITED ST4 UNITED ST2 1995 22787003
+UNITED ST3 UNITED ST8 1995 22505239
+UNITED ST9 UNITED ST8 1995 21292527
+UNITED ST8 UNITED ST4 1995 19287311
+UNITED ST8 UNITED ST2 1995 18282990
+UNITED ST9 UNITED ST3 1995 17539102
+UNITED ST3 UNITED ST6 1995 16738530
+UNITED ST0 UNITED ST8 1995 16393249
+UNITED ST5 UNITED ST2 1995 14951023
+UNITED ST2 UNITED ST2 1995 13455031
+UNITED ST5 UNITED ST8 1995 13346932
+UNITED ST3 UNITED ST2 1995 12886829
+UNITED ST9 UNITED ST2 1995 12653362
+UNITED ST0 UNITED ST5 1995 11453709
+UNITED ST6 UNITED ST2 1995 11363551
+UNITED ST8 UNITED ST8 1995 11285867
+UNITED ST1 UNITED ST2 1995 7991676
+UNITED ST0 UNITED ST2 1995 4776460
+UNITED ST7 UNITED ST2 1995 3973565
+UNITED ST6 UNITED ST0 1996 132286763
+UNITED ST4 UNITED ST0 1996 106897563
+UNITED ST5 UNITED ST0 1996 104501979
+UNITED ST0 UNITED ST4 1996 103228749
+UNITED ST9 UNITED ST1 1996 101983827
+UNITED ST1 UNITED ST0 1996 94861554
+UNITED ST0 UNITED ST1 1996 91948777
+UNITED ST6 UNITED ST1 1996 89705870
+UNITED ST2 UNITED ST1 1996 88256155
+UNITED ST1 UNITED ST1 1996 87265848
+UNITED ST4 UNITED ST7 1996 83677814
+UNITED ST6 UNITED ST3 1996 82168229
+UNITED ST2 UNITED ST7 1996 80468477
+UNITED ST8 UNITED ST1 1996 78971756
+UNITED ST7 UNITED ST4 1996 77941011
+UNITED ST1 UNITED ST3 1996 77610905
+UNITED ST9 UNITED ST9 1996 77301740
+UNITED ST0 UNITED ST9 1996 75935209
+UNITED ST7 UNITED ST0 1996 75602445
+UNITED ST3 UNITED ST1 1996 74746699
+UNITED ST7 UNITED ST7 1996 74040644
+UNITED ST4 UNITED ST1 1996 72819867
+UNITED ST5 UNITED ST9 1996 72614114
+UNITED ST1 UNITED ST9 1996 69823769
+UNITED ST9 UNITED ST4 1996 69616614
+UNITED ST6 UNITED ST4 1996 69296005
+UNITED ST2 UNITED ST0 1996 67095122
+UNITED ST5 UNITED ST1 1996 65346389
+UNITED ST6 UNITED ST9 1996 63256182
+UNITED ST4 UNITED ST6 1996 62189328
+UNITED ST0 UNITED ST0 1996 61528855
+UNITED ST8 UNITED ST9 1996 60466691
+UNITED ST3 UNITED ST0 1996 60226840
+UNITED ST8 UNITED ST6 1996 59746655
+UNITED ST2 UNITED ST3 1996 59648598
+UNITED ST0 UNITED ST5 1996 57762895
+UNITED ST8 UNITED ST7 1996 57523925
+UNITED ST2 UNITED ST4 1996 57487057
+UNITED ST6 UNITED ST7 1996 57090619
+UNITED ST3 UNITED ST4 1996 54838259
+UNITED ST4 UNITED ST9 1996 54134840
+UNITED ST1 UNITED ST6 1996 54056366
+UNITED ST3 UNITED ST7 1996 53987218
+UNITED ST2 UNITED ST9 1996 53491415
+UNITED ST4 UNITED ST8 1996 53035662
+UNITED ST9 UNITED ST5 1996 52825922
+UNITED ST7 UNITED ST3 1996 52356886
+UNITED ST6 UNITED ST8 1996 52136784
+UNITED ST1 UNITED ST5 1996 51189649
+UNITED ST8 UNITED ST4 1996 51033054
+UNITED ST1 UNITED ST4 1996 50135547
+UNITED ST3 UNITED ST9 1996 49612304
+UNITED ST9 UNITED ST0 1996 49590701
+UNITED ST3 UNITED ST3 1996 49263796
+UNITED ST9 UNITED ST7 1996 48798759
+UNITED ST7 UNITED ST1 1996 48784175
+UNITED ST9 UNITED ST6 1996 48685063
+UNITED ST2 UNITED ST5 1996 47028976
+UNITED ST9 UNITED ST3 1996 47021018
+UNITED ST2 UNITED ST8 1996 46865113
+UNITED ST4 UNITED ST3 1996 46460940
+UNITED ST6 UNITED ST5 1996 46030104
+UNITED ST2 UNITED ST6 1996 45416649
+UNITED ST8 UNITED ST5 1996 43480473
+UNITED ST5 UNITED ST5 1996 43020722
+UNITED ST6 UNITED ST6 1996 42923032
+UNITED ST4 UNITED ST5 1996 42808412
+UNITED ST3 UNITED ST6 1996 41881628
+UNITED ST1 UNITED ST7 1996 41721506
+UNITED ST5 UNITED ST7 1996 40946330
+UNITED ST8 UNITED ST0 1996 39845427
+UNITED ST8 UNITED ST3 1996 39535940
+UNITED ST1 UNITED ST8 1996 39430882
+UNITED ST5 UNITED ST6 1996 38332044
+UNITED ST0 UNITED ST6 1996 37232062
+UNITED ST7 UNITED ST6 1996 36535628
+UNITED ST9 UNITED ST8 1996 36112301
+UNITED ST3 UNITED ST8 1996 33924732
+UNITED ST3 UNITED ST5 1996 33717439
+UNITED ST5 UNITED ST4 1996 33424859
+UNITED ST5 UNITED ST3 1996 32919926
+UNITED ST4 UNITED ST4 1996 32787995
+UNITED ST7 UNITED ST5 1996 32784224
+UNITED ST5 UNITED ST8 1996 32415682
+UNITED ST0 UNITED ST7 1996 31391181
+UNITED ST0 UNITED ST3 1996 29795665
+UNITED ST7 UNITED ST9 1996 25028091
+UNITED ST7 UNITED ST8 1996 24348851
+UNITED ST6 UNITED ST2 1996 20447847
+UNITED ST8 UNITED ST8 1996 16340603
+UNITED ST0 UNITED ST8 1996 15168262
+UNITED ST4 UNITED ST2 1996 12451867
+UNITED ST1 UNITED ST2 1996 10082536
+UNITED ST5 UNITED ST2 1996 8544233
+UNITED ST7 UNITED ST2 1996 8390470
+UNITED ST9 UNITED ST2 1996 8108035
+UNITED ST8 UNITED ST2 1996 7028334
+UNITED ST0 UNITED ST2 1996 6907199
+UNITED ST3 UNITED ST2 1996 4311800
+UNITED ST5 UNITED ST0 1997 121457766
+UNITED ST0 UNITED ST9 1997 119856268
+UNITED ST5 UNITED ST1 1997 106900161
+UNITED ST9 UNITED ST9 1997 106222795
+UNITED ST5 UNITED ST4 1997 103432927
+UNITED ST7 UNITED ST1 1997 101326940
+UNITED ST5 UNITED ST9 1997 97392640
+UNITED ST8 UNITED ST0 1997 89434845
+UNITED ST1 UNITED ST3 1997 85175638
+UNITED ST4 UNITED ST1 1997 84611188
+UNITED ST4 UNITED ST7 1997 84606996
+UNITED ST1 UNITED ST4 1997 83092569
+UNITED ST0 UNITED ST1 1997 80167139
+UNITED ST4 UNITED ST9 1997 79697927
+UNITED ST1 UNITED ST0 1997 77667866
+UNITED ST2 UNITED ST0 1997 77591470
+UNITED ST1 UNITED ST7 1997 77045722
+UNITED ST2 UNITED ST7 1997 76483802
+UNITED ST1 UNITED ST1 1997 76340444
+UNITED ST0 UNITED ST7 1997 72577490
+UNITED ST4 UNITED ST0 1997 69875804
+UNITED ST6 UNITED ST3 1997 69725506
+UNITED ST2 UNITED ST9 1997 69543984
+UNITED ST7 UNITED ST0 1997 69354312
+UNITED ST9 UNITED ST7 1997 69052630
+UNITED ST8 UNITED ST3 1997 66918394
+UNITED ST0 UNITED ST0 1997 66308516
+UNITED ST9 UNITED ST0 1997 66066791
+UNITED ST2 UNITED ST3 1997 65429453
+UNITED ST2 UNITED ST1 1997 65396135
+UNITED ST4 UNITED ST4 1997 62532346
+UNITED ST9 UNITED ST1 1997 62418406
+UNITED ST3 UNITED ST7 1997 61095300
+UNITED ST7 UNITED ST4 1997 60123494
+UNITED ST4 UNITED ST3 1997 59634153
+UNITED ST3 UNITED ST4 1997 58356141
+UNITED ST6 UNITED ST9 1997 58231263
+UNITED ST6 UNITED ST4 1997 57215022
+UNITED ST2 UNITED ST4 1997 57012611
+UNITED ST5 UNITED ST3 1997 56789932
+UNITED ST9 UNITED ST5 1997 56091920
+UNITED ST6 UNITED ST0 1997 55824919
+UNITED ST6 UNITED ST1 1997 55117709
+UNITED ST7 UNITED ST9 1997 55039970
+UNITED ST5 UNITED ST7 1997 54534315
+UNITED ST3 UNITED ST1 1997 54150683
+UNITED ST3 UNITED ST0 1997 54050172
+UNITED ST3 UNITED ST9 1997 51370308
+UNITED ST1 UNITED ST5 1997 51052110
+UNITED ST6 UNITED ST7 1997 49795849
+UNITED ST5 UNITED ST6 1997 49030016
+UNITED ST1 UNITED ST9 1997 48944111
+UNITED ST3 UNITED ST3 1997 48385233
+UNITED ST0 UNITED ST5 1997 47988418
+UNITED ST2 UNITED ST8 1997 46391909
+UNITED ST4 UNITED ST6 1997 46236849
+UNITED ST9 UNITED ST3 1997 46121724
+UNITED ST8 UNITED ST9 1997 45852796
+UNITED ST7 UNITED ST8 1997 45476266
+UNITED ST8 UNITED ST1 1997 43284139
+UNITED ST7 UNITED ST7 1997 42566603
+UNITED ST0 UNITED ST4 1997 41193803
+UNITED ST8 UNITED ST7 1997 40878429
+UNITED ST8 UNITED ST8 1997 40749400
+UNITED ST2 UNITED ST5 1997 40662886
+UNITED ST0 UNITED ST3 1997 40078508
+UNITED ST6 UNITED ST8 1997 37988445
+UNITED ST9 UNITED ST6 1997 37596882
+UNITED ST6 UNITED ST5 1997 37571788
+UNITED ST2 UNITED ST2 1997 37034333
+UNITED ST7 UNITED ST5 1997 36889736
+UNITED ST8 UNITED ST4 1997 36600584
+UNITED ST3 UNITED ST6 1997 36075844
+UNITED ST7 UNITED ST3 1997 35168922
+UNITED ST2 UNITED ST6 1997 34274467
+UNITED ST5 UNITED ST8 1997 32910946
+UNITED ST3 UNITED ST5 1997 32811963
+UNITED ST4 UNITED ST8 1997 32599736
+UNITED ST5 UNITED ST5 1997 32568888
+UNITED ST4 UNITED ST5 1997 31995868
+UNITED ST9 UNITED ST4 1997 31765478
+UNITED ST7 UNITED ST2 1997 31409590
+UNITED ST9 UNITED ST8 1997 31272385
+UNITED ST0 UNITED ST8 1997 30241370
+UNITED ST3 UNITED ST8 1997 29102220
+UNITED ST7 UNITED ST6 1997 27539931
+UNITED ST8 UNITED ST5 1997 26673743
+UNITED ST6 UNITED ST6 1997 24983291
+UNITED ST0 UNITED ST2 1997 23584229
+UNITED ST0 UNITED ST6 1997 22924046
+UNITED ST1 UNITED ST2 1997 20599130
+UNITED ST8 UNITED ST6 1997 20073000
+UNITED ST1 UNITED ST6 1997 18205326
+UNITED ST1 UNITED ST8 1997 15375258
+UNITED ST6 UNITED ST2 1997 14746680
+UNITED ST5 UNITED ST2 1997 13863438
+UNITED ST8 UNITED ST2 1997 12053706
+UNITED ST3 UNITED ST2 1997 7891878
+UNITED ST4 UNITED ST2 1997 2848157
+UNITED ST9 UNITED ST2 1997 2661652
+
diff --git a/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q3.3.out b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q3.3.out
new file mode 100644
index 0000000000..96695e04c8
--- /dev/null
+++ b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q3.3.out
@@ -0,0 +1,27 @@
+-- This file is automatically generated. You should know what you did if you want to edit this
+-- !q3.3 --
+UNITED KI1 UNITED KI1 1992 46735995
+UNITED KI5 UNITED KI1 1992 36277055
+UNITED KI5 UNITED KI5 1992 25355267
+UNITED KI1 UNITED KI5 1992 21917846
+UNITED KI5 UNITED KI1 1993 61017607
+UNITED KI1 UNITED KI1 1993 45669535
+UNITED KI5 UNITED KI5 1993 34099392
+UNITED KI1 UNITED KI5 1993 21444206
+UNITED KI5 UNITED KI1 1994 36282163
+UNITED KI1 UNITED KI1 1994 34868441
+UNITED KI5 UNITED KI5 1994 34507284
+UNITED KI1 UNITED KI5 1994 21221780
+UNITED KI5 UNITED KI1 1995 82955896
+UNITED KI1 UNITED KI1 1995 35881186
+UNITED KI5 UNITED KI5 1995 20539805
+UNITED KI1 UNITED KI5 1995 17176510
+UNITED KI5 UNITED KI1 1996 65767049
+UNITED KI1 UNITED KI1 1996 59923037
+UNITED KI5 UNITED KI5 1996 46077342
+UNITED KI1 UNITED KI5 1996 13700254
+UNITED KI1 UNITED KI1 1997 70343133
+UNITED KI5 UNITED KI1 1997 64978359
+UNITED KI5 UNITED KI5 1997 27332027
+UNITED KI1 UNITED KI5 1997 16410668
+
diff --git a/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q3.4.out b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q3.4.out
new file mode 100644
index 0000000000..136aefa350
--- /dev/null
+++ b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q3.4.out
@@ -0,0 +1,6 @@
+-- This file is automatically generated. You should know what you did if you want to edit this
+-- !q3.4 --
+UNITED KI5 UNITED KI1 1997 9117846
+UNITED KI5 UNITED KI5 1997 6203801
+UNITED KI1 UNITED KI5 1997 1870070
+
diff --git a/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q4.1.out b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q4.1.out
new file mode 100644
index 0000000000..485ce1aa92
--- /dev/null
+++ b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q4.1.out
@@ -0,0 +1,38 @@
+-- This file is automatically generated. You should know what you did if you want to edit this
+-- !q4.1 --
+1992 ARGENTINA 9658964469
+1992 BRAZIL 9226983055
+1992 CANADA 9643176787
+1992 PERU 9410676597
+1992 UNITED STATES 9849427653
+1993 ARGENTINA 9976332853
+1993 BRAZIL 9468799229
+1993 CANADA 9897302420
+1993 PERU 9309445836
+1993 UNITED STATES 10003985086
+1994 ARGENTINA 9940305215
+1994 BRAZIL 9348651677
+1994 CANADA 9582647596
+1994 PERU 9295265013
+1994 UNITED STATES 9519880425
+1995 ARGENTINA 10143841380
+1995 BRAZIL 9156077350
+1995 CANADA 9562612160
+1995 PERU 9778087211
+1995 UNITED STATES 9310565244
+1996 ARGENTINA 10001927895
+1996 BRAZIL 9168485151
+1996 CANADA 10061604203
+1996 PERU 9355135674
+1996 UNITED STATES 9769712174
+1997 ARGENTINA 9854560261
+1997 BRAZIL 9121571047
+1997 CANADA 10097371778
+1997 PERU 9315525917
+1997 UNITED STATES 10506723879
+1998 ARGENTINA 5834240407
+1998 BRAZIL 5356398095
+1998 CANADA 5423211196
+1998 PERU 5726185970
+1998 UNITED STATES 6009462019
+
diff --git a/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q4.2.out b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q4.2.out
new file mode 100644
index 0000000000..600a018fb4
--- /dev/null
+++ b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q4.2.out
@@ -0,0 +1,103 @@
+-- This file is automatically generated. You should know what you did if you want to edit this
+-- !q4.2 --
+1997 ARGENTINA MFGR#11 907071566
+1997 ARGENTINA MFGR#12 924115562
+1997 ARGENTINA MFGR#13 972861821
+1997 ARGENTINA MFGR#14 975410345
+1997 ARGENTINA MFGR#15 938867375
+1997 ARGENTINA MFGR#21 1014782574
+1997 ARGENTINA MFGR#22 873016783
+1997 ARGENTINA MFGR#23 1030357302
+1997 ARGENTINA MFGR#24 893460579
+1997 ARGENTINA MFGR#25 1006311403
+1997 BRAZIL MFGR#11 1073219328
+1997 BRAZIL MFGR#12 989858833
+1997 BRAZIL MFGR#13 1128480379
+1997 BRAZIL MFGR#14 1194256722
+1997 BRAZIL MFGR#15 1094419124
+1997 BRAZIL MFGR#21 910026832
+1997 BRAZIL MFGR#22 993142048
+1997 BRAZIL MFGR#23 1107672874
+1997 BRAZIL MFGR#24 1058013649
+1997 BRAZIL MFGR#25 994733764
+1997 CANADA MFGR#11 854725020
+1997 CANADA MFGR#12 938718164
+1997 CANADA MFGR#13 959265890
+1997 CANADA MFGR#14 1002812450
+1997 CANADA MFGR#15 848183013
+1997 CANADA MFGR#21 999805272
+1997 CANADA MFGR#22 778419763
+1997 CANADA MFGR#23 928359645
+1997 CANADA MFGR#24 849895128
+1997 CANADA MFGR#25 904587965
+1997 PERU MFGR#11 1100242877
+1997 PERU MFGR#12 994365350
+1997 PERU MFGR#13 847486105
+1997 PERU MFGR#14 947769683
+1997 PERU MFGR#15 999395678
+1997 PERU MFGR#21 867923394
+1997 PERU MFGR#22 988747459
+1997 PERU MFGR#23 1066645086
+1997 PERU MFGR#24 935665725
+1997 PERU MFGR#25 981454129
+1997 UNITED STATES MFGR#11 1046706048
+1997 UNITED STATES MFGR#12 909213709
+1997 UNITED STATES MFGR#13 1096278906
+1997 UNITED STATES MFGR#14 934282111
+1997 UNITED STATES MFGR#15 962760843
+1997 UNITED STATES MFGR#21 1000676474
+1997 UNITED STATES MFGR#22 1076947615
+1997 UNITED STATES MFGR#23 937288102
+1997 UNITED STATES MFGR#24 1003386363
+1997 UNITED STATES MFGR#25 1053666052
+1998 ARGENTINA MFGR#11 567612227
+1998 ARGENTINA MFGR#12 527025042
+1998 ARGENTINA MFGR#13 582791792
+1998 ARGENTINA MFGR#14 523726368
+1998 ARGENTINA MFGR#15 522078267
+1998 ARGENTINA MFGR#21 504712685
+1998 ARGENTINA MFGR#22 506061736
+1998 ARGENTINA MFGR#23 560479801
+1998 ARGENTINA MFGR#24 524579118
+1998 ARGENTINA MFGR#25 547840211
+1998 BRAZIL MFGR#11 638578488
+1998 BRAZIL MFGR#12 646312681
+1998 BRAZIL MFGR#13 655161772
+1998 BRAZIL MFGR#14 552676170
+1998 BRAZIL MFGR#15 663812709
+1998 BRAZIL MFGR#21 668822448
+1998 BRAZIL MFGR#22 591791918
+1998 BRAZIL MFGR#23 690648877
+1998 BRAZIL MFGR#24 562362220
+1998 BRAZIL MFGR#25 704182376
+1998 CANADA MFGR#11 509086125
+1998 CANADA MFGR#12 488089772
+1998 CANADA MFGR#13 486533297
+1998 CANADA MFGR#14 527837227
+1998 CANADA MFGR#15 535869299
+1998 CANADA MFGR#21 455868651
+1998 CANADA MFGR#22 594277308
+1998 CANADA MFGR#23 574125070
+1998 CANADA MFGR#24 508530424
+1998 CANADA MFGR#25 547757992
+1998 PERU MFGR#11 567838547
+1998 PERU MFGR#12 540544757
+1998 PERU MFGR#13 591331883
+1998 PERU MFGR#14 481335064
+1998 PERU MFGR#15 570246138
+1998 PERU MFGR#21 533733330
+1998 PERU MFGR#22 527790656
+1998 PERU MFGR#23 636393221
+1998 PERU MFGR#24 589075262
+1998 PERU MFGR#25 543251115
+1998 UNITED STATES MFGR#11 556276232
+1998 UNITED STATES MFGR#12 612385982
+1998 UNITED STATES MFGR#13 622413927
+1998 UNITED STATES MFGR#14 555006887
+1998 UNITED STATES MFGR#15 525119569
+1998 UNITED STATES MFGR#21 563406836
+1998 UNITED STATES MFGR#22 580478735
+1998 UNITED STATES MFGR#23 656080465
+1998 UNITED STATES MFGR#24 538445058
+1998 UNITED STATES MFGR#25 589111952
+
diff --git a/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q4.3.out b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q4.3.out
new file mode 100644
index 0000000000..09c8399d00
--- /dev/null
+++ b/regression-test/data/ssb_sf1_unique_sql_zstd/sql/q4.3.out
@@ -0,0 +1,697 @@
+-- This file is automatically generated. You should know what you did if you want to edit this
+-- !q4.3 --
+1997 UNITED ST0 MFGR#141 15456288
+1997 UNITED ST0 MFGR#1410 32961113
+1997 UNITED ST0 MFGR#1411 36166400
+1997 UNITED ST0 MFGR#1412 18237451
+1997 UNITED ST0 MFGR#1413 40752813
+1997 UNITED ST0 MFGR#1414 24237588
+1997 UNITED ST0 MFGR#1415 6419001
+1997 UNITED ST0 MFGR#1416 15639876
+1997 UNITED ST0 MFGR#1417 15476211
+1997 UNITED ST0 MFGR#1418 8169956
+1997 UNITED ST0 MFGR#1419 18217252
+1997 UNITED ST0 MFGR#142 29361222
+1997 UNITED ST0 MFGR#1420 34587603
+1997 UNITED ST0 MFGR#1421 28560921
+1997 UNITED ST0 MFGR#1422 25154181
+1997 UNITED ST0 MFGR#1423 18144008
+1997 UNITED ST0 MFGR#1424 28064267
+1997 UNITED ST0 MFGR#1425 15255845
+1997 UNITED ST0 MFGR#1426 5610353
+1997 UNITED ST0 MFGR#1427 5750693
+1997 UNITED ST0 MFGR#1428 14081707
+1997 UNITED ST0 MFGR#1429 9024512
+1997 UNITED ST0 MFGR#143 5325193
+1997 UNITED ST0 MFGR#1430 16961739
+1997 UNITED ST0 MFGR#1431 19015253
+1997 UNITED ST0 MFGR#1432 6324917
+1997 UNITED ST0 MFGR#1433 6734461
+1997 UNITED ST0 MFGR#1434 19206393
+1997 UNITED ST0 MFGR#1435 679925
+1997 UNITED ST0 MFGR#1436 13834012
+1997 UNITED ST0 MFGR#1437 23575407
+1997 UNITED ST0 MFGR#1438 24756074
+1997 UNITED ST0 MFGR#1439 19644072
+1997 UNITED ST0 MFGR#144 20285157
+1997 UNITED ST0 MFGR#1440 14068558
+1997 UNITED ST0 MFGR#145 22646138
+1997 UNITED ST0 MFGR#146 16381159
+1997 UNITED ST0 MFGR#147 12267827
+1997 UNITED ST0 MFGR#148 30968614
+1997 UNITED ST0 MFGR#149 8640669
+1997 UNITED ST1 MFGR#141 10152087
+1997 UNITED ST1 MFGR#1410 32583300
+1997 UNITED ST1 MFGR#1411 15690352
+1997 UNITED ST1 MFGR#1412 16671403
+1997 UNITED ST1 MFGR#1413 4942775
+1997 UNITED ST1 MFGR#1414 9391597
+1997 UNITED ST1 MFGR#1415 26937296
+1997 UNITED ST1 MFGR#1416 25782871
+1997 UNITED ST1 MFGR#1417 23349641
+1997 UNITED ST1 MFGR#1418 10934620
+1997 UNITED ST1 MFGR#1419 22673030
+1997 UNITED ST1 MFGR#142 14048276
+1997 UNITED ST1 MFGR#1420 18100795
+1997 UNITED ST1 MFGR#1421 25405678
+1997 UNITED ST1 MFGR#1423 5713800
+1997 UNITED ST1 MFGR#1424 4131923
+1997 UNITED ST1 MFGR#1425 17190425
+1997 UNITED ST1 MFGR#1426 22314044
+1997 UNITED ST1 MFGR#1427 13635057
+1997 UNITED ST1 MFGR#1428 17735811
+1997 UNITED ST1 MFGR#1429 28740911
+1997 UNITED ST1 MFGR#143 27418033
+1997 UNITED ST1 MFGR#1430 18655292
+1997 UNITED ST1 MFGR#1431 11074399
+1997 UNITED ST1 MFGR#1432 7490170
+1997 UNITED ST1 MFGR#1433 28997266
+1997 UNITED ST1 MFGR#1434 4612211
+1997 UNITED ST1 MFGR#1435 16327124
+1997 UNITED ST1 MFGR#1436 17409665
+1997 UNITED ST1 MFGR#1437 33391635
+1997 UNITED ST1 MFGR#1438 37321134
+1997 UNITED ST1 MFGR#1439 10279941
+1997 UNITED ST1 MFGR#144 12304723
+1997 UNITED ST1 MFGR#1440 28921230
+1997 UNITED ST1 MFGR#145 17933684
+1997 UNITED ST1 MFGR#146 8709103
+1997 UNITED ST1 MFGR#147 20145983
+1997 UNITED ST1 MFGR#148 16940400
+1997 UNITED ST1 MFGR#149 10284949
+1997 UNITED ST2 MFGR#1412 6328240
+1997 UNITED ST2 MFGR#1415 5022682
+1997 UNITED ST2 MFGR#1416 4102214
+1997 UNITED ST2 MFGR#1417 5284444
+1997 UNITED ST2 MFGR#1418 2649908
+1997 UNITED ST2 MFGR#1419 4664673
+1997 UNITED ST2 MFGR#142 10784835
+1997 UNITED ST2 MFGR#1423 4095190
+1997 UNITED ST2 MFGR#1424 5376355
+1997 UNITED ST2 MFGR#1425 3949957
+1997 UNITED ST2 MFGR#143 2859829
+1997 UNITED ST2 MFGR#1430 4618266
+1997 UNITED ST2 MFGR#1432 5183060
+1997 UNITED ST2 MFGR#1433 10531371
+1997 UNITED ST2 MFGR#1434 77646
+1997 UNITED ST2 MFGR#1436 6538508
+1997 UNITED ST2 MFGR#1438 12324747
+1997 UNITED ST2 MFGR#144 2002870
+1997 UNITED ST2 MFGR#1440 12247229
+1997 UNITED ST2 MFGR#145 202685
+1997 UNITED ST2 MFGR#148 5998932
+1997 UNITED ST3 MFGR#141 12866083
+1997 UNITED ST3 MFGR#1410 31051703
+1997 UNITED ST3 MFGR#1411 14099543
+1997 UNITED ST3 MFGR#1412 4970551
+1997 UNITED ST3 MFGR#1413 26129762
+1997 UNITED ST3 MFGR#1414 22364787
+1997 UNITED ST3 MFGR#1415 27883428
+1997 UNITED ST3 MFGR#1416 25289630
+1997 UNITED ST3 MFGR#1417 5524810
+1997 UNITED ST3 MFGR#1419 3616608
+1997 UNITED ST3 MFGR#142 10776059
+1997 UNITED ST3 MFGR#1420 12958851
+1997 UNITED ST3 MFGR#1421 5815494
+1997 UNITED ST3 MFGR#1422 17694270
+1997 UNITED ST3 MFGR#1423 10285142
+1997 UNITED ST3 MFGR#1424 21555317
+1997 UNITED ST3 MFGR#1425 5214517
+1997 UNITED ST3 MFGR#1426 16810700
+1997 UNITED ST3 MFGR#1427 10086430
+1997 UNITED ST3 MFGR#1428 7733716
+1997 UNITED ST3 MFGR#1429 11922430
+1997 UNITED ST3 MFGR#1430 20105292
+1997 UNITED ST3 MFGR#1431 14716979
+1997 UNITED ST3 MFGR#1432 15779247
+1997 UNITED ST3 MFGR#1433 15308773
+1997 UNITED ST3 MFGR#1434 8515037
+1997 UNITED ST3 MFGR#1435 25486899
+1997 UNITED ST3 MFGR#1436 12739448
+1997 UNITED ST3 MFGR#1437 11249180
+1997 UNITED ST3 MFGR#1438 4156824
+1997 UNITED ST3 MFGR#1439 18358277
+1997 UNITED ST3 MFGR#144 10097718
+1997 UNITED ST3 MFGR#1440 22920494
+1997 UNITED ST3 MFGR#145 20285859
+1997 UNITED ST3 MFGR#146 18406423
+1997 UNITED ST3 MFGR#147 17295990
+1997 UNITED ST3 MFGR#148 26127145
+1997 UNITED ST3 MFGR#149 19895538
+1997 UNITED ST4 MFGR#141 8135477
+1997 UNITED ST4 MFGR#1410 5503247
+1997 UNITED ST4 MFGR#1411 6096435
+1997 UNITED ST4 MFGR#1412 19976043
+1997 UNITED ST4 MFGR#1413 22581282
+1997 UNITED ST4 MFGR#1414 10101379
+1997 UNITED ST4 MFGR#1415 8877444
+1997 UNITED ST4 MFGR#1416 17943398
+1997 UNITED ST4 MFGR#1417 9224501
+1997 UNITED ST4 MFGR#1418 16255176
+1997 UNITED ST4 MFGR#1419 683069
+1997 UNITED ST4 MFGR#142 23512944
+1997 UNITED ST4 MFGR#1420 27954262
+1997 UNITED ST4 MFGR#1421 54209185
+1997 UNITED ST4 MFGR#1422 1173957
+1997 UNITED ST4 MFGR#1423 20410710
+1997 UNITED ST4 MFGR#1424 2889270
+1997 UNITED ST4 MFGR#1425 13361796
+1997 UNITED ST4 MFGR#1426 18678819
+1997 UNITED ST4 MFGR#1427 18206066
+1997 UNITED ST4 MFGR#1428 18153974
+1997 UNITED ST4 MFGR#1429 12545076
+1997 UNITED ST4 MFGR#143 6158834
+1997 UNITED ST4 MFGR#1430 16128370
+1997 UNITED ST4 MFGR#1431 11153717
+1997 UNITED ST4 MFGR#1432 7745636
+1997 UNITED ST4 MFGR#1433 15983634
+1997 UNITED ST4 MFGR#1434 3662246
+1997 UNITED ST4 MFGR#1435 3060180
+1997 UNITED ST4 MFGR#1436 11524592
+1997 UNITED ST4 MFGR#1437 36824174
+1997 UNITED ST4 MFGR#1438 8226666
+1997 UNITED ST4 MFGR#1439 9872470
+1997 UNITED ST4 MFGR#1440 401207
+1997 UNITED ST4 MFGR#145 11698312
+1997 UNITED ST4 MFGR#146 18259956
+1997 UNITED ST4 MFGR#147 10256110
+1997 UNITED ST4 MFGR#148 15892628
+1997 UNITED ST4 MFGR#149 4322491
+1997 UNITED ST5 MFGR#141 8534275
+1997 UNITED ST5 MFGR#1411 2427261
+1997 UNITED ST5 MFGR#1412 9032422
+1997 UNITED ST5 MFGR#1413 6343588
+1997 UNITED ST5 MFGR#1414 2961025
+1997 UNITED ST5 MFGR#1415 21186568
+1997 UNITED ST5 MFGR#1416 9354080
+1997 UNITED ST5 MFGR#1417 11786246
+1997 UNITED ST5 MFGR#1418 15297245
+1997 UNITED ST5 MFGR#1420 15787608
+1997 UNITED ST5 MFGR#1421 17858301
+1997 UNITED ST5 MFGR#1422 14080987
+1997 UNITED ST5 MFGR#1423 12535186
+1997 UNITED ST5 MFGR#1424 3221960
+1997 UNITED ST5 MFGR#1425 8950317
+1997 UNITED ST5 MFGR#1426 13161486
+1997 UNITED ST5 MFGR#1427 6149737
+1997 UNITED ST5 MFGR#1428 6796520
+1997 UNITED ST5 MFGR#1429 26026300
+1997 UNITED ST5 MFGR#143 6712572
+1997 UNITED ST5 MFGR#1430 16092131
+1997 UNITED ST5 MFGR#1431 3425291
+1997 UNITED ST5 MFGR#1432 14630175
+1997 UNITED ST5 MFGR#1433 4967585
+1997 UNITED ST5 MFGR#1434 6716261
+1997 UNITED ST5 MFGR#1435 6290790
+1997 UNITED ST5 MFGR#1436 6787699
+1997 UNITED ST5 MFGR#1437 6045168
+1997 UNITED ST5 MFGR#1438 1082877
+1997 UNITED ST5 MFGR#1439 5268611
+1997 UNITED ST5 MFGR#144 8900840
+1997 UNITED ST5 MFGR#1440 2644336
+1997 UNITED ST5 MFGR#145 18054844
+1997 UNITED ST5 MFGR#146 4893668
+1997 UNITED ST5 MFGR#147 9615891
+1997 UNITED ST5 MFGR#148 1426124
+1997 UNITED ST5 MFGR#149 7320726
+1997 UNITED ST6 MFGR#141 10051337
+1997 UNITED ST6 MFGR#1410 23352963
+1997 UNITED ST6 MFGR#1411 1537303
+1997 UNITED ST6 MFGR#1412 4332646
+1997 UNITED ST6 MFGR#1413 14686752
+1997 UNITED ST6 MFGR#1414 7226409
+1997 UNITED ST6 MFGR#1415 15062686
+1997 UNITED ST6 MFGR#1416 8606480
+1997 UNITED ST6 MFGR#1417 7662761
+1997 UNITED ST6 MFGR#1418 1810860
+1997 UNITED ST6 MFGR#1419 20179568
+1997 UNITED ST6 MFGR#142 15506072
+1997 UNITED ST6 MFGR#1420 3844271
+1997 UNITED ST6 MFGR#1421 10608709
+1997 UNITED ST6 MFGR#1422 16083699
+1997 UNITED ST6 MFGR#1423 6789571
+1997 UNITED ST6 MFGR#1424 17631950
+1997 UNITED ST6 MFGR#1425 8477221
+1997 UNITED ST6 MFGR#1426 16847029
+1997 UNITED ST6 MFGR#1428 17314796
+1997 UNITED ST6 MFGR#1429 19175871
+1997 UNITED ST6 MFGR#143 8775848
+1997 UNITED ST6 MFGR#1431 5319063
+1997 UNITED ST6 MFGR#1432 7875606
+1997 UNITED ST6 MFGR#1433 9305264
+1997 UNITED ST6 MFGR#1434 8050404
+1997 UNITED ST6 MFGR#1435 17585836
+1997 UNITED ST6 MFGR#1436 13745758
+1997 UNITED ST6 MFGR#1438 14536324
+1997 UNITED ST6 MFGR#1439 11451329
+1997 UNITED ST6 MFGR#144 10794837
+1997 UNITED ST6 MFGR#1440 5719238
+1997 UNITED ST6 MFGR#145 25449058
+1997 UNITED ST6 MFGR#146 17821996
+1997 UNITED ST6 MFGR#147 18922333
+1997 UNITED ST6 MFGR#148 10825718
+1997 UNITED ST6 MFGR#149 14950868
+1997 UNITED ST7 MFGR#141 8291476
+1997 UNITED ST7 MFGR#1410 4622953
+1997 UNITED ST7 MFGR#1411 14885507
+1997 UNITED ST7 MFGR#1412 19011375
+1997 UNITED ST7 MFGR#1413 31178370
+1997 UNITED ST7 MFGR#1414 16429613
+1997 UNITED ST7 MFGR#1415 3091832
+1997 UNITED ST7 MFGR#1416 17008243
+1997 UNITED ST7 MFGR#1417 15609283
+1997 UNITED ST7 MFGR#1418 5059394
+1997 UNITED ST7 MFGR#1419 7234721
+1997 UNITED ST7 MFGR#142 6898938
+1997 UNITED ST7 MFGR#1420 6426590
+1997 UNITED ST7 MFGR#1421 6043221
+1997 UNITED ST7 MFGR#1422 13273021
+1997 UNITED ST7 MFGR#1423 30537249
+1997 UNITED ST7 MFGR#1424 9224296
+1997 UNITED ST7 MFGR#1425 12799069
+1997 UNITED ST7 MFGR#1426 30277891
+1997 UNITED ST7 MFGR#1427 8331493
+1997 UNITED ST7 MFGR#1428 16205423
+1997 UNITED ST7 MFGR#1429 14396627
+1997 UNITED ST7 MFGR#143 10209623
+1997 UNITED ST7 MFGR#1430 16556758
+1997 UNITED ST7 MFGR#1431 15775327
+1997 UNITED ST7 MFGR#1432 24602989
+1997 UNITED ST7 MFGR#1433 22927717
+1997 UNITED ST7 MFGR#1434 9486462
+1997 UNITED ST7 MFGR#1435 14254290
+1997 UNITED ST7 MFGR#1436 8645365
+1997 UNITED ST7 MFGR#1437 19026166
+1997 UNITED ST7 MFGR#1438 11291550
+1997 UNITED ST7 MFGR#1439 9590292
+1997 UNITED ST7 MFGR#144 14110404
+1997 UNITED ST7 MFGR#1440 21877355
+1997 UNITED ST7 MFGR#145 8246717
+1997 UNITED ST7 MFGR#146 9785781
+1997 UNITED ST7 MFGR#147 13412691
+1997 UNITED ST7 MFGR#148 14235939
+1997 UNITED ST7 MFGR#149 23450309
+1997 UNITED ST8 MFGR#141 7323416
+1997 UNITED ST8 MFGR#1410 7191961
+1997 UNITED ST8 MFGR#1411 2425849
+1997 UNITED ST8 MFGR#1412 26725641
+1997 UNITED ST8 MFGR#1413 7915896
+1997 UNITED ST8 MFGR#1414 14359044
+1997 UNITED ST8 MFGR#1415 15834927
+1997 UNITED ST8 MFGR#1416 7464470
+1997 UNITED ST8 MFGR#1417 15274496
+1997 UNITED ST8 MFGR#1418 3261391
+1997 UNITED ST8 MFGR#1419 8020386
+1997 UNITED ST8 MFGR#142 5985550
+1997 UNITED ST8 MFGR#1420 9441461
+1997 UNITED ST8 MFGR#1421 2998735
+1997 UNITED ST8 MFGR#1423 1565415
+1997 UNITED ST8 MFGR#1424 5613094
+1997 UNITED ST8 MFGR#1425 7186734
+1997 UNITED ST8 MFGR#1426 3153117
+1997 UNITED ST8 MFGR#1427 11303043
+1997 UNITED ST8 MFGR#1428 3564003
+1997 UNITED ST8 MFGR#143 6357477
+1997 UNITED ST8 MFGR#1430 6633950
+1997 UNITED ST8 MFGR#1431 867285
+1997 UNITED ST8 MFGR#1432 9962884
+1997 UNITED ST8 MFGR#1433 13708011
+1997 UNITED ST8 MFGR#1434 7357067
+1997 UNITED ST8 MFGR#1435 11993453
+1997 UNITED ST8 MFGR#1436 7231938
+1997 UNITED ST8 MFGR#1437 18632056
+1997 UNITED ST8 MFGR#1438 3609384
+1997 UNITED ST8 MFGR#144 4822734
+1997 UNITED ST8 MFGR#1440 2521917
+1997 UNITED ST8 MFGR#145 11683385
+1997 UNITED ST8 MFGR#146 3350415
+1997 UNITED ST8 MFGR#147 8425393
+1997 UNITED ST8 MFGR#148 15005341
+1997 UNITED ST8 MFGR#149 9018101
+1997 UNITED ST9 MFGR#141 21838850
+1997 UNITED ST9 MFGR#1410 8455387
+1997 UNITED ST9 MFGR#1411 27984689
+1997 UNITED ST9 MFGR#1412 26491401
+1997 UNITED ST9 MFGR#1413 30237705
+1997 UNITED ST9 MFGR#1414 8957476
+1997 UNITED ST9 MFGR#1415 35391583
+1997 UNITED ST9 MFGR#1416 8923782
+1997 UNITED ST9 MFGR#1417 3210984
+1997 UNITED ST9 MFGR#1418 12102607
+1997 UNITED ST9 MFGR#1419 14468627
+1997 UNITED ST9 MFGR#142 33363582
+1997 UNITED ST9 MFGR#1420 13139731
+1997 UNITED ST9 MFGR#1421 8410650
+1997 UNITED ST9 MFGR#1422 11268410
+1997 UNITED ST9 MFGR#1423 2846614
+1997 UNITED ST9 MFGR#1424 2305872
+1997 UNITED ST9 MFGR#1425 4896060
+1997 UNITED ST9 MFGR#1426 31544772
+1997 UNITED ST9 MFGR#1427 4113085
+1997 UNITED ST9 MFGR#1428 11137081
+1997 UNITED ST9 MFGR#1429 10633230
+1997 UNITED ST9 MFGR#143 11438203
+1997 UNITED ST9 MFGR#1430 2727389
+1997 UNITED ST9 MFGR#1431 10548538
+1997 UNITED ST9 MFGR#1433 26564495
+1997 UNITED ST9 MFGR#1434 11948206
+1997 UNITED ST9 MFGR#1435 2201909
+1997 UNITED ST9 MFGR#1436 10347631
+1997 UNITED ST9 MFGR#1437 40051690
+1997 UNITED ST9 MFGR#1438 2662945
+1997 UNITED ST9 MFGR#1439 18011455
+1997 UNITED ST9 MFGR#144 10202784
+1997 UNITED ST9 MFGR#1440 11123196
+1997 UNITED ST9 MFGR#145 11326624
+1997 UNITED ST9 MFGR#146 27825456
+1997 UNITED ST9 MFGR#147 17579502
+1997 UNITED ST9 MFGR#148 17001116
+1998 UNITED ST0 MFGR#141 12484786
+1998 UNITED ST0 MFGR#1410 5225999
+1998 UNITED ST0 MFGR#1411 2633395
+1998 UNITED ST0 MFGR#1412 9479536
+1998 UNITED ST0 MFGR#1413 18468711
+1998 UNITED ST0 MFGR#1414 19440601
+1998 UNITED ST0 MFGR#1415 16894643
+1998 UNITED ST0 MFGR#1416 7520117
+1998 UNITED ST0 MFGR#1417 464576
+1998 UNITED ST0 MFGR#1418 5171747
+1998 UNITED ST0 MFGR#1419 5970985
+1998 UNITED ST0 MFGR#142 23830409
+1998 UNITED ST0 MFGR#1420 2568835
+1998 UNITED ST0 MFGR#1421 6096442
+1998 UNITED ST0 MFGR#1422 10099456
+1998 UNITED ST0 MFGR#1423 24617746
+1998 UNITED ST0 MFGR#1424 22853888
+1998 UNITED ST0 MFGR#1425 25622112
+1998 UNITED ST0 MFGR#1426 9630701
+1998 UNITED ST0 MFGR#1427 4952625
+1998 UNITED ST0 MFGR#1428 4675471
+1998 UNITED ST0 MFGR#1429 19713527
+1998 UNITED ST0 MFGR#143 4971265
+1998 UNITED ST0 MFGR#1430 13948705
+1998 UNITED ST0 MFGR#1431 2955181
+1998 UNITED ST0 MFGR#1432 17946759
+1998 UNITED ST0 MFGR#1433 23325027
+1998 UNITED ST0 MFGR#1434 8580738
+1998 UNITED ST0 MFGR#1435 6663914
+1998 UNITED ST0 MFGR#1436 13468582
+1998 UNITED ST0 MFGR#1437 9419979
+1998 UNITED ST0 MFGR#1438 16164522
+1998 UNITED ST0 MFGR#1439 8692866
+1998 UNITED ST0 MFGR#144 17338711
+1998 UNITED ST0 MFGR#1440 8513736
+1998 UNITED ST0 MFGR#145 6212569
+1998 UNITED ST0 MFGR#146 2702349
+1998 UNITED ST0 MFGR#149 8844540
+1998 UNITED ST1 MFGR#141 13449110
+1998 UNITED ST1 MFGR#1410 5224626
+1998 UNITED ST1 MFGR#1411 16046399
+1998 UNITED ST1 MFGR#1412 8424392
+1998 UNITED ST1 MFGR#1413 7634982
+1998 UNITED ST1 MFGR#1414 8711782
+1998 UNITED ST1 MFGR#1415 5991201
+1998 UNITED ST1 MFGR#1416 11059645
+1998 UNITED ST1 MFGR#1417 8108087
+1998 UNITED ST1 MFGR#1418 1710875
+1998 UNITED ST1 MFGR#1419 452298
+1998 UNITED ST1 MFGR#142 6186526
+1998 UNITED ST1 MFGR#1421 4766963
+1998 UNITED ST1 MFGR#1422 5556563
+1998 UNITED ST1 MFGR#1423 12110257
+1998 UNITED ST1 MFGR#1424 8924948
+1998 UNITED ST1 MFGR#1425 5684710
+1998 UNITED ST1 MFGR#1426 6844444
+1998 UNITED ST1 MFGR#1427 7625525
+1998 UNITED ST1 MFGR#1428 5227395
+1998 UNITED ST1 MFGR#1429 2855272
+1998 UNITED ST1 MFGR#143 6964811
+1998 UNITED ST1 MFGR#1430 16952380
+1998 UNITED ST1 MFGR#1431 7655883
+1998 UNITED ST1 MFGR#1432 2975960
+1998 UNITED ST1 MFGR#1433 10175594
+1998 UNITED ST1 MFGR#1434 26358848
+1998 UNITED ST1 MFGR#1435 11408623
+1998 UNITED ST1 MFGR#1436 4438242
+1998 UNITED ST1 MFGR#1437 10014906
+1998 UNITED ST1 MFGR#1438 18817171
+1998 UNITED ST1 MFGR#1439 2129973
+1998 UNITED ST1 MFGR#144 9512727
+1998 UNITED ST1 MFGR#1440 20185179
+1998 UNITED ST1 MFGR#145 823605
+1998 UNITED ST1 MFGR#146 9358026
+1998 UNITED ST1 MFGR#147 6552312
+1998 UNITED ST1 MFGR#148 9144461
+1998 UNITED ST1 MFGR#149 2149639
+1998 UNITED ST2 MFGR#1410 8044368
+1998 UNITED ST2 MFGR#1413 727343
+1998 UNITED ST2 MFGR#1414 251088
+1998 UNITED ST2 MFGR#1416 5224696
+1998 UNITED ST2 MFGR#1419 7917142
+1998 UNITED ST2 MFGR#1420 9848986
+1998 UNITED ST2 MFGR#1427 4816976
+1998 UNITED ST2 MFGR#1429 4196069
+1998 UNITED ST2 MFGR#143 10073044
+1998 UNITED ST2 MFGR#1431 877123
+1998 UNITED ST2 MFGR#1433 3740836
+1998 UNITED ST2 MFGR#1434 857691
+1998 UNITED ST2 MFGR#1435 2277870
+1998 UNITED ST2 MFGR#145 4906521
+1998 UNITED ST2 MFGR#149 842348
+1998 UNITED ST3 MFGR#141 4181582
+1998 UNITED ST3 MFGR#1410 3169761
+1998 UNITED ST3 MFGR#1412 6590440
+1998 UNITED ST3 MFGR#1413 2015369
+1998 UNITED ST3 MFGR#1414 4408466
+1998 UNITED ST3 MFGR#1415 3963826
+1998 UNITED ST3 MFGR#1416 3179540
+1998 UNITED ST3 MFGR#1417 11440999
+1998 UNITED ST3 MFGR#1418 8725751
+1998 UNITED ST3 MFGR#1419 10646990
+1998 UNITED ST3 MFGR#142 5056172
+1998 UNITED ST3 MFGR#1420 3583150
+1998 UNITED ST3 MFGR#1421 7085689
+1998 UNITED ST3 MFGR#1422 20858904
+1998 UNITED ST3 MFGR#1423 12825743
+1998 UNITED ST3 MFGR#1424 3533518
+1998 UNITED ST3 MFGR#1425 4938324
+1998 UNITED ST3 MFGR#1426 15164664
+1998 UNITED ST3 MFGR#1427 2619162
+1998 UNITED ST3 MFGR#1428 7723699
+1998 UNITED ST3 MFGR#143 24362893
+1998 UNITED ST3 MFGR#1430 7139650
+1998 UNITED ST3 MFGR#1431 10306394
+1998 UNITED ST3 MFGR#1432 14769004
+1998 UNITED ST3 MFGR#1433 9610545
+1998 UNITED ST3 MFGR#1435 6611760
+1998 UNITED ST3 MFGR#1436 941348
+1998 UNITED ST3 MFGR#1437 4802162
+1998 UNITED ST3 MFGR#1438 5079750
+1998 UNITED ST3 MFGR#1439 5905118
+1998 UNITED ST3 MFGR#144 5436839
+1998 UNITED ST3 MFGR#1440 9815517
+1998 UNITED ST3 MFGR#145 7580271
+1998 UNITED ST3 MFGR#146 14051404
+1998 UNITED ST3 MFGR#147 7786017
+1998 UNITED ST3 MFGR#149 1271813
+1998 UNITED ST4 MFGR#141 26703183
+1998 UNITED ST4 MFGR#1410 18094129
+1998 UNITED ST4 MFGR#1411 615999
+1998 UNITED ST4 MFGR#1412 13988709
+1998 UNITED ST4 MFGR#1413 10115647
+1998 UNITED ST4 MFGR#1414 1586551
+1998 UNITED ST4 MFGR#1415 14357244
+1998 UNITED ST4 MFGR#1416 9430036
+1998 UNITED ST4 MFGR#1417 17361773
+1998 UNITED ST4 MFGR#1418 10187338
+1998 UNITED ST4 MFGR#1419 7116094
+1998 UNITED ST4 MFGR#142 18454502
+1998 UNITED ST4 MFGR#1420 1621340
+1998 UNITED ST4 MFGR#1422 13861291
+1998 UNITED ST4 MFGR#1423 4208006
+1998 UNITED ST4 MFGR#1424 3242576
+1998 UNITED ST4 MFGR#1425 1470642
+1998 UNITED ST4 MFGR#1426 11987205
+1998 UNITED ST4 MFGR#1427 12975399
+1998 UNITED ST4 MFGR#1428 11756155
+1998 UNITED ST4 MFGR#1429 6956191
+1998 UNITED ST4 MFGR#143 11499476
+1998 UNITED ST4 MFGR#1430 4355096
+1998 UNITED ST4 MFGR#1431 20166612
+1998 UNITED ST4 MFGR#1432 8849789
+1998 UNITED ST4 MFGR#1433 10786037
+1998 UNITED ST4 MFGR#1435 13208151
+1998 UNITED ST4 MFGR#1436 4747808
+1998 UNITED ST4 MFGR#1437 12999351
+1998 UNITED ST4 MFGR#1438 17360787
+1998 UNITED ST4 MFGR#1439 2557841
+1998 UNITED ST4 MFGR#144 22030911
+1998 UNITED ST4 MFGR#145 5272280
+1998 UNITED ST4 MFGR#146 4307958
+1998 UNITED ST4 MFGR#147 7995050
+1998 UNITED ST4 MFGR#148 2348889
+1998 UNITED ST5 MFGR#141 8396190
+1998 UNITED ST5 MFGR#1410 17422889
+1998 UNITED ST5 MFGR#1411 764246
+1998 UNITED ST5 MFGR#1413 8051561
+1998 UNITED ST5 MFGR#1414 1500867
+1998 UNITED ST5 MFGR#1416 3874315
+1998 UNITED ST5 MFGR#1417 7550747
+1998 UNITED ST5 MFGR#1418 14241755
+1998 UNITED ST5 MFGR#1419 4893846
+1998 UNITED ST5 MFGR#142 5418299
+1998 UNITED ST5 MFGR#1420 3810727
+1998 UNITED ST5 MFGR#1421 3321336
+1998 UNITED ST5 MFGR#1423 5021100
+1998 UNITED ST5 MFGR#1424 6125645
+1998 UNITED ST5 MFGR#1426 880680
+1998 UNITED ST5 MFGR#1427 1284890
+1998 UNITED ST5 MFGR#1428 3813108
+1998 UNITED ST5 MFGR#1429 9429868
+1998 UNITED ST5 MFGR#143 15699981
+1998 UNITED ST5 MFGR#1430 7977654
+1998 UNITED ST5 MFGR#1431 5545969
+1998 UNITED ST5 MFGR#1432 1803434
+1998 UNITED ST5 MFGR#1435 12957056
+1998 UNITED ST5 MFGR#1436 20666755
+1998 UNITED ST5 MFGR#1437 9536733
+1998 UNITED ST5 MFGR#1439 11784214
+1998 UNITED ST5 MFGR#1440 613089
+1998 UNITED ST5 MFGR#145 8237944
+1998 UNITED ST5 MFGR#147 5370351
+1998 UNITED ST6 MFGR#141 6683977
+1998 UNITED ST6 MFGR#1411 11589040
+1998 UNITED ST6 MFGR#1412 4800954
+1998 UNITED ST6 MFGR#1416 5848432
+1998 UNITED ST6 MFGR#1417 1804324
+1998 UNITED ST6 MFGR#1418 4642727
+1998 UNITED ST6 MFGR#1419 10079621
+1998 UNITED ST6 MFGR#142 2533570
+1998 UNITED ST6 MFGR#1420 9016258
+1998 UNITED ST6 MFGR#1421 7636150
+1998 UNITED ST6 MFGR#1422 1272436
+1998 UNITED ST6 MFGR#1423 9600097
+1998 UNITED ST6 MFGR#1424 7036762
+1998 UNITED ST6 MFGR#1425 10867426
+1998 UNITED ST6 MFGR#1426 7033994
+1998 UNITED ST6 MFGR#1427 6481679
+1998 UNITED ST6 MFGR#1428 6269185
+1998 UNITED ST6 MFGR#1429 12055631
+1998 UNITED ST6 MFGR#143 6500459
+1998 UNITED ST6 MFGR#1430 6816243
+1998 UNITED ST6 MFGR#1432 7752973
+1998 UNITED ST6 MFGR#1436 6292813
+1998 UNITED ST6 MFGR#1437 2334894
+1998 UNITED ST6 MFGR#1438 4459455
+1998 UNITED ST6 MFGR#144 640220
+1998 UNITED ST6 MFGR#1440 748200
+1998 UNITED ST6 MFGR#145 7948794
+1998 UNITED ST6 MFGR#146 2734333
+1998 UNITED ST6 MFGR#147 2995632
+1998 UNITED ST6 MFGR#148 10695287
+1998 UNITED ST6 MFGR#149 1475864
+1998 UNITED ST7 MFGR#141 4816637
+1998 UNITED ST7 MFGR#1410 24393912
+1998 UNITED ST7 MFGR#1411 1283038
+1998 UNITED ST7 MFGR#1412 12607459
+1998 UNITED ST7 MFGR#1413 15421293
+1998 UNITED ST7 MFGR#1414 7681668
+1998 UNITED ST7 MFGR#1415 7138377
+1998 UNITED ST7 MFGR#1416 9246990
+1998 UNITED ST7 MFGR#1417 5242972
+1998 UNITED ST7 MFGR#1419 13548941
+1998 UNITED ST7 MFGR#142 17758762
+1998 UNITED ST7 MFGR#1420 11980437
+1998 UNITED ST7 MFGR#1421 11166952
+1998 UNITED ST7 MFGR#1422 9231883
+1998 UNITED ST7 MFGR#1424 5796389
+1998 UNITED ST7 MFGR#1425 4943582
+1998 UNITED ST7 MFGR#1426 16361100
+1998 UNITED ST7 MFGR#1427 9659296
+1998 UNITED ST7 MFGR#1428 2998020
+1998 UNITED ST7 MFGR#1429 5766768
+1998 UNITED ST7 MFGR#143 5526167
+1998 UNITED ST7 MFGR#1430 4191892
+1998 UNITED ST7 MFGR#1431 12979559
+1998 UNITED ST7 MFGR#1432 5832068
+1998 UNITED ST7 MFGR#1433 11410227
+1998 UNITED ST7 MFGR#1434 10525792
+1998 UNITED ST7 MFGR#1435 5982420
+1998 UNITED ST7 MFGR#1436 7142934
+1998 UNITED ST7 MFGR#1437 7499671
+1998 UNITED ST7 MFGR#1438 9177564
+1998 UNITED ST7 MFGR#1439 1974444
+1998 UNITED ST7 MFGR#144 2428463
+1998 UNITED ST7 MFGR#1440 3300838
+1998 UNITED ST7 MFGR#146 1771645
+1998 UNITED ST7 MFGR#147 4681835
+1998 UNITED ST7 MFGR#148 7124367
+1998 UNITED ST7 MFGR#149 11662970
+1998 UNITED ST8 MFGR#141 12753354
+1998 UNITED ST8 MFGR#1410 1097292
+1998 UNITED ST8 MFGR#1411 4069881
+1998 UNITED ST8 MFGR#1414 9474831
+1998 UNITED ST8 MFGR#1415 6406304
+1998 UNITED ST8 MFGR#1418 2392133
+1998 UNITED ST8 MFGR#1419 2953230
+1998 UNITED ST8 MFGR#142 10702563
+1998 UNITED ST8 MFGR#1420 3719432
+1998 UNITED ST8 MFGR#1421 3854657
+1998 UNITED ST8 MFGR#1422 9711968
+1998 UNITED ST8 MFGR#1424 1102516
+1998 UNITED ST8 MFGR#1426 8937532
+1998 UNITED ST8 MFGR#1427 5255637
+1998 UNITED ST8 MFGR#1428 1695112
+1998 UNITED ST8 MFGR#143 6231349
+1998 UNITED ST8 MFGR#1430 4678664
+1998 UNITED ST8 MFGR#1431 2459741
+1998 UNITED ST8 MFGR#1433 1724339
+1998 UNITED ST8 MFGR#1434 8222328
+1998 UNITED ST8 MFGR#1435 4087165
+1998 UNITED ST8 MFGR#1437 7379288
+1998 UNITED ST8 MFGR#1439 1947163
+1998 UNITED ST8 MFGR#144 21846266
+1998 UNITED ST8 MFGR#146 13768113
+1998 UNITED ST8 MFGR#147 5279643
+1998 UNITED ST8 MFGR#149 15221410
+1998 UNITED ST9 MFGR#141 5544000
+1998 UNITED ST9 MFGR#1410 7971104
+1998 UNITED ST9 MFGR#1411 26426609
+1998 UNITED ST9 MFGR#1412 1701777
+1998 UNITED ST9 MFGR#1413 18786672
+1998 UNITED ST9 MFGR#1414 15787780
+1998 UNITED ST9 MFGR#1415 11214818
+1998 UNITED ST9 MFGR#1416 2076120
+1998 UNITED ST9 MFGR#1417 14310334
+1998 UNITED ST9 MFGR#1418 3558355
+1998 UNITED ST9 MFGR#1419 6134867
+1998 UNITED ST9 MFGR#142 257897
+1998 UNITED ST9 MFGR#1420 7716338
+1998 UNITED ST9 MFGR#1421 10291775
+1998 UNITED ST9 MFGR#1422 6105716
+1998 UNITED ST9 MFGR#1423 11378613
+1998 UNITED ST9 MFGR#1424 1904550
+1998 UNITED ST9 MFGR#1425 18831147
+1998 UNITED ST9 MFGR#1426 18562642
+1998 UNITED ST9 MFGR#1427 12565890
+1998 UNITED ST9 MFGR#1428 10720914
+1998 UNITED ST9 MFGR#1429 21940718
+1998 UNITED ST9 MFGR#143 21480722
+1998 UNITED ST9 MFGR#1430 30935173
+1998 UNITED ST9 MFGR#1431 7793012
+1998 UNITED ST9 MFGR#1432 10026104
+1998 UNITED ST9 MFGR#1433 17874435
+1998 UNITED ST9 MFGR#1434 5493785
+1998 UNITED ST9 MFGR#1435 10738769
+1998 UNITED ST9 MFGR#1436 43504
+1998 UNITED ST9 MFGR#1437 13559646
+1998 UNITED ST9 MFGR#1438 12654258
+1998 UNITED ST9 MFGR#1439 5972923
+1998 UNITED ST9 MFGR#144 15702123
+1998 UNITED ST9 MFGR#1440 6681029
+1998 UNITED ST9 MFGR#145 920718
+1998 UNITED ST9 MFGR#146 10435931
+1998 UNITED ST9 MFGR#147 4759326
+1998 UNITED ST9 MFGR#148 9970848
+1998 UNITED ST9 MFGR#149 7510940
+
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/customer_create.sql b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/customer_create.sql
new file mode 100644
index 0000000000..d172400d82
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/customer_create.sql
@@ -0,0 +1,16 @@
+CREATE TABLE IF NOT EXISTS `customer` (
+ `c_custkey` int(11) NOT NULL COMMENT "",
+ `c_name` varchar(26) NOT NULL COMMENT "",
+ `c_address` varchar(41) NOT NULL COMMENT "",
+ `c_city` varchar(11) NOT NULL COMMENT "",
+ `c_nation` varchar(16) NOT NULL COMMENT "",
+ `c_region` varchar(13) NOT NULL COMMENT "",
+ `c_phone` varchar(16) NOT NULL COMMENT "",
+ `c_mktsegment` varchar(11) NOT NULL COMMENT ""
+)
+UNIQUE KEY (`c_custkey`)
+DISTRIBUTED BY HASH(`c_custkey`) BUCKETS 10
+PROPERTIES (
+"compression"="zstd",
+"replication_num" = "1"
+);
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/customer_delete.sql b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/customer_delete.sql
new file mode 100644
index 0000000000..fe22a226fe
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/customer_delete.sql
@@ -0,0 +1 @@
+truncate table customer;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/customer_part_delete.sql b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/customer_part_delete.sql
new file mode 100644
index 0000000000..f6d0edda74
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/customer_part_delete.sql
@@ -0,0 +1 @@
+delete from customer where c_custkey > 15000 ;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/customer_sequence_create.sql b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/customer_sequence_create.sql
new file mode 100644
index 0000000000..282479442d
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/customer_sequence_create.sql
@@ -0,0 +1,17 @@
+CREATE TABLE IF NOT EXISTS `customer` (
+ `c_custkey` int(11) NOT NULL COMMENT "",
+ `c_name` varchar(26) NOT NULL COMMENT "",
+ `c_address` varchar(41) NOT NULL COMMENT "",
+ `c_city` varchar(11) NOT NULL COMMENT "",
+ `c_nation` varchar(16) NOT NULL COMMENT "",
+ `c_region` varchar(13) NOT NULL COMMENT "",
+ `c_phone` varchar(16) NOT NULL COMMENT "",
+ `c_mktsegment` varchar(11) NOT NULL COMMENT ""
+)
+UNIQUE KEY (`c_custkey`)
+DISTRIBUTED BY HASH(`c_custkey`) BUCKETS 10
+PROPERTIES (
+"function_column.sequence_type" = 'int',
+"compression"="zstd",
+"replication_num" = "1"
+);
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/date_create.sql b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/date_create.sql
new file mode 100644
index 0000000000..830ce3ce59
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/date_create.sql
@@ -0,0 +1,25 @@
+CREATE TABLE IF NOT EXISTS `date` (
+ `d_datekey` int(11) NOT NULL COMMENT "",
+ `d_date` varchar(20) NOT NULL COMMENT "",
+ `d_dayofweek` varchar(10) NOT NULL COMMENT "",
+ `d_month` varchar(11) NOT NULL COMMENT "",
+ `d_year` int(11) NOT NULL COMMENT "",
+ `d_yearmonthnum` int(11) NOT NULL COMMENT "",
+ `d_yearmonth` varchar(9) NOT NULL COMMENT "",
+ `d_daynuminweek` int(11) NOT NULL COMMENT "",
+ `d_daynuminmonth` int(11) NOT NULL COMMENT "",
+ `d_daynuminyear` int(11) NOT NULL COMMENT "",
+ `d_monthnuminyear` int(11) NOT NULL COMMENT "",
+ `d_weeknuminyear` int(11) NOT NULL COMMENT "",
+ `d_sellingseason` varchar(14) NOT NULL COMMENT "",
+ `d_lastdayinweekfl` int(11) NOT NULL COMMENT "",
+ `d_lastdayinmonthfl` int(11) NOT NULL COMMENT "",
+ `d_holidayfl` int(11) NOT NULL COMMENT "",
+ `d_weekdayfl` int(11) NOT NULL COMMENT ""
+)
+UNIQUE KEY (`d_datekey`)
+DISTRIBUTED BY HASH(`d_datekey`) BUCKETS 1
+PROPERTIES (
+"compression"="zstd",
+"replication_num" = "1"
+);
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/date_delete.sql b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/date_delete.sql
new file mode 100644
index 0000000000..12933cbbad
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/date_delete.sql
@@ -0,0 +1 @@
+truncate table `date`;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/date_part_delete.sql b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/date_part_delete.sql
new file mode 100644
index 0000000000..d9ccd7c336
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/date_part_delete.sql
@@ -0,0 +1 @@
+delete from `date` where d_datekey >= '19930101' and d_datekey <= '19951230';
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/date_sequence_create.sql b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/date_sequence_create.sql
new file mode 100644
index 0000000000..662ac4fbd2
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/date_sequence_create.sql
@@ -0,0 +1,26 @@
+CREATE TABLE IF NOT EXISTS `date` (
+ `d_datekey` int(11) NOT NULL COMMENT "",
+ `d_date` varchar(20) NOT NULL COMMENT "",
+ `d_dayofweek` varchar(10) NOT NULL COMMENT "",
+ `d_month` varchar(11) NOT NULL COMMENT "",
+ `d_year` int(11) NOT NULL COMMENT "",
+ `d_yearmonthnum` int(11) NOT NULL COMMENT "",
+ `d_yearmonth` varchar(9) NOT NULL COMMENT "",
+ `d_daynuminweek` int(11) NOT NULL COMMENT "",
+ `d_daynuminmonth` int(11) NOT NULL COMMENT "",
+ `d_daynuminyear` int(11) NOT NULL COMMENT "",
+ `d_monthnuminyear` int(11) NOT NULL COMMENT "",
+ `d_weeknuminyear` int(11) NOT NULL COMMENT "",
+ `d_sellingseason` varchar(14) NOT NULL COMMENT "",
+ `d_lastdayinweekfl` int(11) NOT NULL COMMENT "",
+ `d_lastdayinmonthfl` int(11) NOT NULL COMMENT "",
+ `d_holidayfl` int(11) NOT NULL COMMENT "",
+ `d_weekdayfl` int(11) NOT NULL COMMENT ""
+)
+UNIQUE KEY (`d_datekey`)
+DISTRIBUTED BY HASH(`d_datekey`) BUCKETS 1
+PROPERTIES (
+"function_column.sequence_type" = 'int',
+"compression"="zstd",
+"replication_num" = "1"
+);
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/lineorder_create.sql b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/lineorder_create.sql
new file mode 100644
index 0000000000..d75a3f1ae3
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/lineorder_create.sql
@@ -0,0 +1,33 @@
+CREATE TABLE IF NOT EXISTS `lineorder` (
+ `lo_orderdate` int(11) NOT NULL COMMENT "",
+ `lo_orderkey` bigint(20) NOT NULL COMMENT "",
+ `lo_linenumber` bigint(20) NOT NULL COMMENT "",
+ `lo_custkey` int(11) NOT NULL COMMENT "",
+ `lo_partkey` int(11) NOT NULL COMMENT "",
+ `lo_suppkey` int(11) NOT NULL COMMENT "",
+ `lo_orderpriority` varchar(16) NOT NULL COMMENT "",
+ `lo_shippriority` int(11) NOT NULL COMMENT "",
+ `lo_quantity` bigint(20) NOT NULL COMMENT "",
+ `lo_extendedprice` bigint(20) NOT NULL COMMENT "",
+ `lo_ordtotalprice` bigint(20) NOT NULL COMMENT "",
+ `lo_discount` bigint(20) NOT NULL COMMENT "",
+ `lo_revenue` bigint(20) NOT NULL COMMENT "",
+ `lo_supplycost` bigint(20) NOT NULL COMMENT "",
+ `lo_tax` bigint(20) NOT NULL COMMENT "",
+ `lo_commitdate` bigint(20) NOT NULL COMMENT "",
+ `lo_shipmode` varchar(11) NOT NULL COMMENT ""
+)
+UNIQUE KEY (`lo_orderdate`,`lo_orderkey`,`lo_linenumber`)
+PARTITION BY RANGE(`lo_orderdate`)
+(PARTITION p1992 VALUES [("-2147483648"), ("19930101")),
+PARTITION p1993 VALUES [("19930101"), ("19940101")),
+PARTITION p1994 VALUES [("19940101"), ("19950101")),
+PARTITION p1995 VALUES [("19950101"), ("19960101")),
+PARTITION p1996 VALUES [("19960101"), ("19970101")),
+PARTITION p1997 VALUES [("19970101"), ("19980101")),
+PARTITION p1998 VALUES [("19980101"), ("19990101")))
+DISTRIBUTED BY HASH(`lo_orderkey`) BUCKETS 48
+PROPERTIES (
+"compression"="zstd",
+"replication_num" = "1"
+);
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/lineorder_delete.sql b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/lineorder_delete.sql
new file mode 100644
index 0000000000..329e040060
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/lineorder_delete.sql
@@ -0,0 +1 @@
+truncate table lineorder;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/lineorder_part_delete.sql b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/lineorder_part_delete.sql
new file mode 100644
index 0000000000..3dfa3a69d9
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/lineorder_part_delete.sql
@@ -0,0 +1 @@
+delete from lineorder where lo_orderkey >= 2400001 and lo_orderkey <= 3600000;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/lineorder_sequence_create.sql b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/lineorder_sequence_create.sql
new file mode 100644
index 0000000000..988cad5e2e
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/lineorder_sequence_create.sql
@@ -0,0 +1,34 @@
+CREATE TABLE IF NOT EXISTS `lineorder` (
+ `lo_orderdate` int(11) NOT NULL COMMENT "",
+ `lo_orderkey` bigint(20) NOT NULL COMMENT "",
+ `lo_linenumber` bigint(20) NOT NULL COMMENT "",
+ `lo_custkey` int(11) NOT NULL COMMENT "",
+ `lo_partkey` int(11) NOT NULL COMMENT "",
+ `lo_suppkey` int(11) NOT NULL COMMENT "",
+ `lo_orderpriority` varchar(16) NOT NULL COMMENT "",
+ `lo_shippriority` int(11) NOT NULL COMMENT "",
+ `lo_quantity` bigint(20) NOT NULL COMMENT "",
+ `lo_extendedprice` bigint(20) NOT NULL COMMENT "",
+ `lo_ordtotalprice` bigint(20) NOT NULL COMMENT "",
+ `lo_discount` bigint(20) NOT NULL COMMENT "",
+ `lo_revenue` bigint(20) NOT NULL COMMENT "",
+ `lo_supplycost` bigint(20) NOT NULL COMMENT "",
+ `lo_tax` bigint(20) NOT NULL COMMENT "",
+ `lo_commitdate` bigint(20) NOT NULL COMMENT "",
+ `lo_shipmode` varchar(11) NOT NULL COMMENT ""
+)
+UNIQUE KEY (`lo_orderdate`,`lo_orderkey`,`lo_linenumber`)
+PARTITION BY RANGE(`lo_orderdate`)
+(PARTITION p1992 VALUES [("-2147483648"), ("19930101")),
+PARTITION p1993 VALUES [("19930101"), ("19940101")),
+PARTITION p1994 VALUES [("19940101"), ("19950101")),
+PARTITION p1995 VALUES [("19950101"), ("19960101")),
+PARTITION p1996 VALUES [("19960101"), ("19970101")),
+PARTITION p1997 VALUES [("19970101"), ("19980101")),
+PARTITION p1998 VALUES [("19980101"), ("19990101")))
+DISTRIBUTED BY HASH(`lo_orderkey`) BUCKETS 48
+PROPERTIES (
+"function_column.sequence_type" = 'int',
+"compression"="zstd",
+"replication_num" = "1"
+);
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/part_create.sql b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/part_create.sql
new file mode 100644
index 0000000000..becc59157c
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/part_create.sql
@@ -0,0 +1,17 @@
+CREATE TABLE IF NOT EXISTS `part` (
+ `p_partkey` int(11) NOT NULL COMMENT "",
+ `p_name` varchar(23) NOT NULL COMMENT "",
+ `p_mfgr` varchar(7) NOT NULL COMMENT "",
+ `p_category` varchar(8) NOT NULL COMMENT "",
+ `p_brand` varchar(10) NOT NULL COMMENT "",
+ `p_color` varchar(12) NOT NULL COMMENT "",
+ `p_type` varchar(26) NOT NULL COMMENT "",
+ `p_size` int(11) NOT NULL COMMENT "",
+ `p_container` varchar(11) NOT NULL COMMENT ""
+)
+UNIQUE KEY (`p_partkey`)
+DISTRIBUTED BY HASH(`p_partkey`) BUCKETS 10
+PROPERTIES (
+"compression"="zstd",
+"replication_num" = "1"
+);
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/part_delete.sql b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/part_delete.sql
new file mode 100644
index 0000000000..02c6abd253
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/part_delete.sql
@@ -0,0 +1 @@
+truncate table `part`;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/part_part_delete.sql b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/part_part_delete.sql
new file mode 100644
index 0000000000..9bfcb37904
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/part_part_delete.sql
@@ -0,0 +1 @@
+delete from `part` where p_partkey > 100000;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/part_sequence_create.sql b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/part_sequence_create.sql
new file mode 100644
index 0000000000..89cdb20227
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/part_sequence_create.sql
@@ -0,0 +1,18 @@
+CREATE TABLE IF NOT EXISTS `part` (
+ `p_partkey` int(11) NOT NULL COMMENT "",
+ `p_name` varchar(23) NOT NULL COMMENT "",
+ `p_mfgr` varchar(7) NOT NULL COMMENT "",
+ `p_category` varchar(8) NOT NULL COMMENT "",
+ `p_brand` varchar(10) NOT NULL COMMENT "",
+ `p_color` varchar(12) NOT NULL COMMENT "",
+ `p_type` varchar(26) NOT NULL COMMENT "",
+ `p_size` int(11) NOT NULL COMMENT "",
+ `p_container` varchar(11) NOT NULL COMMENT ""
+)
+UNIQUE KEY (`p_partkey`)
+DISTRIBUTED BY HASH(`p_partkey`) BUCKETS 10
+PROPERTIES (
+"function_column.sequence_type" = 'int',
+"compression"="zstd",
+"replication_num" = "1"
+);
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/supplier_create.sql b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/supplier_create.sql
new file mode 100644
index 0000000000..7839462196
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/supplier_create.sql
@@ -0,0 +1,15 @@
+CREATE TABLE IF NOT EXISTS `supplier` (
+ `s_suppkey` int(11) NOT NULL COMMENT "",
+ `s_name` varchar(26) NOT NULL COMMENT "",
+ `s_address` varchar(26) NOT NULL COMMENT "",
+ `s_city` varchar(11) NOT NULL COMMENT "",
+ `s_nation` varchar(16) NOT NULL COMMENT "",
+ `s_region` varchar(13) NOT NULL COMMENT "",
+ `s_phone` varchar(16) NOT NULL COMMENT ""
+)
+UNIQUE KEY (`s_suppkey`)
+DISTRIBUTED BY HASH(`s_suppkey`) BUCKETS 10
+PROPERTIES (
+"compression"="zstd",
+"replication_num" = "1"
+);
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/supplier_delete.sql b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/supplier_delete.sql
new file mode 100644
index 0000000000..39e663134c
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/supplier_delete.sql
@@ -0,0 +1 @@
+truncate table `supplier`;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/supplier_part_delete.sql b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/supplier_part_delete.sql
new file mode 100644
index 0000000000..431b9bbb82
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/supplier_part_delete.sql
@@ -0,0 +1 @@
+delete from `supplier` where s_suppkey > 1000;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/supplier_sequence_create.sql b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/supplier_sequence_create.sql
new file mode 100644
index 0000000000..e3dcbf33b7
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/ddl/supplier_sequence_create.sql
@@ -0,0 +1,16 @@
+CREATE TABLE IF NOT EXISTS `supplier` (
+ `s_suppkey` int(11) NOT NULL COMMENT "",
+ `s_name` varchar(26) NOT NULL COMMENT "",
+ `s_address` varchar(26) NOT NULL COMMENT "",
+ `s_city` varchar(11) NOT NULL COMMENT "",
+ `s_nation` varchar(16) NOT NULL COMMENT "",
+ `s_region` varchar(13) NOT NULL COMMENT "",
+ `s_phone` varchar(16) NOT NULL COMMENT ""
+)
+UNIQUE KEY (`s_suppkey`)
+DISTRIBUTED BY HASH(`s_suppkey`) BUCKETS 10
+PROPERTIES (
+"function_column.sequence_type" = 'int',
+"compression"="zstd",
+"replication_num" = "1"
+);
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/load_four_step.groovy b/regression-test/suites/ssb_sf1_unique_load_zstd/load_four_step.groovy
new file mode 100644
index 0000000000..37a5f0650a
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/load_four_step.groovy
@@ -0,0 +1,112 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements. See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership. The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied. See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+// Most of the cases are copied from https://github.com/trinodb/trino/tree/master
+// /testing/trino-product-tests/src/main/resources/sql-tests/testcases
+// and modified by Doris.
+
+suite("load_four_step") {
+ def url = "https://doris-community-test-1308700295.cos.ap-hongkong.myqcloud.com"
+ def tables = ["customer": ["""c_custkey,c_name,c_address,c_city,c_nation,c_region,c_phone,c_mktsegment,no_use""", 30000, "c_custkey", 15000], "lineorder": ["""lo_orderkey,lo_linenumber,lo_custkey,lo_partkey,lo_suppkey,lo_orderdate,lo_orderpriority,
+ lo_shippriority,lo_quantity,lo_extendedprice,lo_ordtotalprice,lo_discount,
+ lo_revenue,lo_supplycost,lo_tax,lo_commitdate,lo_shipmode,lo_dummy""", 6001215, "lo_orderkey", 4799919], "part": ["""p_partkey,p_name,p_mfgr,p_category,p_brand,p_color,p_type,p_size,p_container,p_dummy""", 200000, "p_partkey", 100000], "date": ["""d_datekey,d_date,d_dayofweek,d_month,d_year,d_yearmonthnum,d_yearmonth,
+ d_daynuminweek,d_daynuminmonth,d_daynuminyear,d_monthnuminyear,d_weeknuminyear,
+ d_sellingseason,d_lastdayinweekfl,d_lastdayinmonthfl,d_holidayfl,d_weekdayfl,d_dummy""", 2556, "d_datekey", 1462], "supplier": ["""s_suppkey,s_name,s_address,s_city,s_nation,s_region,s_phone,s_dummy""", 2000, "s_suppkey", 1000]]
+
+ tables.each { tableName, rows ->
+ String fileName = """${context.sf1DataPath}/ssb/sf1/${tableName}.tbl.gz"""
+ if (!new File(fileName).isAbsolute()) {
+ fileName = new File(context.dataPath, fileName).getAbsolutePath()
+ }
+ if (!new File(fileName).exists()) {
+ fileName = """${url}/ssb/sf1/${tableName}.tbl.gz"""
+ }
+ sql """ DROP TABLE IF EXISTS $tableName """
+ sql new File("""${context.file.parent}/ddl/${tableName}_sequence_create.sql""").text
+ for (j in 0..<2) {
+ streamLoad {
+ table tableName
+ set 'column_separator', '|'
+ set 'compress_type', 'GZ'
+ set 'columns', rows[0]
+ set 'function_column.sequence_col', rows[2]
+ file fileName
+
+ time 10000 // limit inflight 10s
+
+ // stream load action will check result, include Success status, and NumberTotalRows == NumberLoadedRows
+
+ // if declared a check callback, the default check condition will ignore.
+ // So you must check all condition
+ check { result, exception, startTime, endTime ->
+ if (exception != null) {
+ throw exception
+ }
+ log.info("Stream load result: ${result}".toString())
+ def json = parseJson(result)
+ assertEquals("success", json.Status.toLowerCase())
+ assertEquals(json.NumberTotalRows, json.NumberLoadedRows)
+ assertTrue(json.NumberLoadedRows > 0 && json.LoadBytes > 0)
+ }
+ }
+ sql 'sync'
+ for (int i = 1; i <= 5; i++) {
+ def loadRowCount = sql "select count(1) from ${tableName}"
+ logger.info("select ${tableName} numbers: ${loadRowCount[0][0]}".toString())
+ assertTrue(loadRowCount[0][0] == rows[1])
+ }
+ }
+ sql """ set delete_without_partition = true; """
+ sql new File("""${context.file.parent}/ddl/${tableName}_part_delete.sql""").text
+ for (int i = 1; i <= 5; i++) {
+ def loadRowCount = sql "select count(1) from ${tableName}"
+ logger.info("select ${tableName} numbers: ${loadRowCount[0][0]}".toString())
+ assertTrue(loadRowCount[0][0] == rows[3])
+ }
+ streamLoad {
+ table tableName
+ set 'column_separator', '|'
+ set 'compress_type', 'GZ'
+ set 'columns', rows[0]
+ set 'function_column.sequence_col', rows[2]
+ file """${getS3Url() + '/regression/ssb/sf1/' + tableName}.tbl.gz"""
+
+ time 10000 // limit inflight 10s
+
+ // stream load action will check result, include Success status, and NumberTotalRows == NumberLoadedRows
+
+ // if declared a check callback, the default check condition will ignore.
+ // So you must check all condition
+ check { result, exception, startTime, endTime ->
+ if (exception != null) {
+ throw exception
+ }
+ log.info("Stream load result: ${result}".toString())
+ def json = parseJson(result)
+ assertEquals("success", json.Status.toLowerCase())
+ assertEquals(json.NumberTotalRows, json.NumberLoadedRows)
+ assertTrue(json.NumberLoadedRows > 0 && json.LoadBytes > 0)
+ }
+ }
+ sql 'sync'
+ for (int i = 1; i <= 5; i++) {
+ def loadRowCount = sql "select count(1) from ${tableName}"
+ logger.info("select ${tableName} numbers: ${loadRowCount[0][0]}".toString())
+ assertTrue(loadRowCount[0][0] == rows[1])
+ }
+ }
+}
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/load_one_step.groovy b/regression-test/suites/ssb_sf1_unique_load_zstd/load_one_step.groovy
new file mode 100644
index 0000000000..c8acd0eaa4
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/load_one_step.groovy
@@ -0,0 +1,68 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements. See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership. The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied. See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+
+suite("load_one_step") {
+ def url = "https://doris-community-test-1308700295.cos.ap-hongkong.myqcloud.com"
+ def tables = ["customer": ["""c_custkey,c_name,c_address,c_city,c_nation,c_region,c_phone,c_mktsegment,no_use""", 30000], "lineorder": ["""lo_orderkey,lo_linenumber,lo_custkey,lo_partkey,lo_suppkey,lo_orderdate,lo_orderpriority,
+ lo_shippriority,lo_quantity,lo_extendedprice,lo_ordtotalprice,lo_discount,
+ lo_revenue,lo_supplycost,lo_tax,lo_commitdate,lo_shipmode,lo_dummy""", 6001215], "part": ["""p_partkey,p_name,p_mfgr,p_category,p_brand,p_color,p_type,p_size,p_container,p_dummy""", 200000], "date": ["""d_datekey,d_date,d_dayofweek,d_month,d_year,d_yearmonthnum,d_yearmonth,
+ d_daynuminweek,d_daynuminmonth,d_daynuminyear,d_monthnuminyear,d_weeknuminyear,
+ d_sellingseason,d_lastdayinweekfl,d_lastdayinmonthfl,d_holidayfl,d_weekdayfl,d_dummy""", 2556], "supplier": ["""s_suppkey,s_name,s_address,s_city,s_nation,s_region,s_phone,s_dummy""", 2000]]
+
+ tables.each { tableName, rows ->
+ String fileName = """${context.sf1DataPath}/ssb/sf1/${tableName}.tbl.gz"""
+ if (!new File(fileName).isAbsolute()) {
+ fileName = new File(context.dataPath, fileName).getAbsolutePath()
+ }
+ if (!new File(fileName).exists()) {
+ fileName = """${url}/ssb/sf1/${tableName}.tbl.gz"""
+ }
+ sql """ DROP TABLE IF EXISTS $tableName """
+ sql new File("""${context.file.parent}/ddl/${tableName}_create.sql""").text
+ streamLoad {
+ table tableName
+ set 'column_separator', '|'
+ set 'compress_type', 'GZ'
+ set 'columns', rows[0]
+ file fileName
+
+ time 10000 // limit inflight 10s
+
+ // stream load action will check result, include Success status, and NumberTotalRows == NumberLoadedRows
+
+ // if declared a check callback, the default check condition will ignore.
+ // So you must check all condition
+ check { result, exception, startTime, endTime ->
+ if (exception != null) {
+ throw exception
+ }
+ log.info("Stream load result: ${result}".toString())
+ def json = parseJson(result)
+ assertEquals("success", json.Status.toLowerCase())
+ assertEquals(json.NumberTotalRows, json.NumberLoadedRows)
+ assertTrue(json.NumberLoadedRows > 0 && json.LoadBytes > 0)
+ }
+ }
+ sql 'sync'
+ for (int i = 1; i <= 5; i++) {
+ def loadRowCount = sql "select count(1) from ${tableName}"
+ logger.info("select ${tableName} numbers: ${loadRowCount[0][0]}".toString())
+ assertTrue(loadRowCount[0][0] == rows[1])
+ }
+ }
+}
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/load_three_step.groovy b/regression-test/suites/ssb_sf1_unique_load_zstd/load_three_step.groovy
new file mode 100644
index 0000000000..5294c3186b
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/load_three_step.groovy
@@ -0,0 +1,77 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements. See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership. The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied. See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+
+suite("load_three_step") {
+ def url = "https://doris-community-test-1308700295.cos.ap-hongkong.myqcloud.com"
+ def tables = ["customer": ["""c_custkey,c_name,c_address,c_city,c_nation,c_region,c_phone,c_mktsegment,no_use""", 30000, "c_custkey"], "lineorder": ["""lo_orderkey,lo_linenumber,lo_custkey,lo_partkey,lo_suppkey,lo_orderdate,lo_orderpriority,
+ lo_shippriority,lo_quantity,lo_extendedprice,lo_ordtotalprice,lo_discount,
+ lo_revenue,lo_supplycost,lo_tax,lo_commitdate,lo_shipmode,lo_dummy""", 6001215, "lo_orderkey"], "part": ["""p_partkey,p_name,p_mfgr,p_category,p_brand,p_color,p_type,p_size,p_container,p_dummy""", 200000, "p_partkey"], "date": ["""d_datekey,d_date,d_dayofweek,d_month,d_year,d_yearmonthnum,d_yearmonth,
+ d_daynuminweek,d_daynuminmonth,d_daynuminyear,d_monthnuminyear,d_weeknuminyear,
+ d_sellingseason,d_lastdayinweekfl,d_lastdayinmonthfl,d_holidayfl,d_weekdayfl,d_dummy""", 2556, "d_datekey"], "supplier": ["""s_suppkey,s_name,s_address,s_city,s_nation,s_region,s_phone,s_dummy""", 2000, "s_suppkey"]]
+
+ tables.each { tableName, rows ->
+ String fileName = """${context.sf1DataPath}/ssb/sf1/${tableName}.tbl.gz"""
+ if (!new File(fileName).isAbsolute()) {
+ fileName = new File(context.dataPath, fileName).getAbsolutePath()
+ }
+ if (!new File(fileName).exists()) {
+ fileName = """${url}/ssb/sf1/${tableName}.tbl.gz"""
+ }
+ sql """ DROP TABLE IF EXISTS $tableName """
+ sql new File("""${context.file.parent}/ddl/${tableName}_sequence_create.sql""").text
+ for (j in 0..<2) {
+ streamLoad {
+ table tableName
+ set 'column_separator', '|'
+ set 'compress_type', 'GZ'
+ set 'columns', rows[0]
+ set 'function_column.sequence_col', rows[2]
+ file fileName
+
+ time 10000 // limit inflight 10s
+
+ // stream load action will check result, include Success status, and NumberTotalRows == NumberLoadedRows
+
+ // if declared a check callback, the default check condition will ignore.
+ // So you must check all condition
+ check { result, exception, startTime, endTime ->
+ if (exception != null) {
+ throw exception
+ }
+ log.info("Stream load result: ${result}".toString())
+ def json = parseJson(result)
+ assertEquals("success", json.Status.toLowerCase())
+ assertEquals(json.NumberTotalRows, json.NumberLoadedRows)
+ assertTrue(json.NumberLoadedRows > 0 && json.LoadBytes > 0)
+ }
+ }
+ sql 'sync'
+ for (int i = 1; i <= 5; i++) {
+ def loadRowCount = sql "select count(1) from ${tableName}"
+ logger.info("select ${tableName} numbers: ${loadRowCount[0][0]}".toString())
+ assertTrue(loadRowCount[0][0] == rows[1])
+ }
+ }
+ sql new File("""${context.file.parent}/ddl/${tableName}_delete.sql""").text
+ for (int i = 1; i <= 5; i++) {
+ def loadRowCount = sql "select count(1) from ${tableName}"
+ logger.info("select ${tableName} numbers: ${loadRowCount[0][0]}".toString())
+ assertTrue(loadRowCount[0][0] == 0)
+ }
+ }
+}
diff --git a/regression-test/suites/ssb_sf1_unique_load_zstd/load_two_step.groovy b/regression-test/suites/ssb_sf1_unique_load_zstd/load_two_step.groovy
new file mode 100644
index 0000000000..b576deb4a3
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_load_zstd/load_two_step.groovy
@@ -0,0 +1,75 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements. See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership. The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied. See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+
+suite("load_two_step") {
+ def url = "https://doris-community-test-1308700295.cos.ap-hongkong.myqcloud.com"
+ def tables = ["customer": ["""c_custkey,c_name,c_address,c_city,c_nation,c_region,c_phone,c_mktsegment,no_use""", 30000, "c_custkey"], "lineorder": ["""lo_orderkey,lo_linenumber,lo_custkey,lo_partkey,lo_suppkey,lo_orderdate,lo_orderpriority,
+ lo_shippriority,lo_quantity,lo_extendedprice,lo_ordtotalprice,lo_discount,
+ lo_revenue,lo_supplycost,lo_tax,lo_commitdate,lo_shipmode,lo_dummy""", 6001215, "lo_orderkey"], "part": ["""p_partkey,p_name,p_mfgr,p_category,p_brand,p_color,p_type,p_size,p_container,p_dummy""", 200000, "p_partkey"], "date": ["""d_datekey,d_date,d_dayofweek,d_month,d_year,d_yearmonthnum,d_yearmonth,
+ d_daynuminweek,d_daynuminmonth,d_daynuminyear,d_monthnuminyear,d_weeknuminyear,
+ d_sellingseason,d_lastdayinweekfl,d_lastdayinmonthfl,d_holidayfl,d_weekdayfl,d_dummy""", 2556, "d_datekey"], "supplier": ["""s_suppkey,s_name,s_address,s_city,s_nation,s_region,s_phone,s_dummy""", 2000, "s_suppkey"]]
+
+ tables.each { tableName, rows ->
+ String fileName = """${context.sf1DataPath}/ssb/sf1/${tableName}.tbl.gz"""
+ if (!new File(fileName).isAbsolute()) {
+ fileName = new File(context.dataPath, fileName).getAbsolutePath()
+ }
+ if (!new File(fileName).exists()) {
+ fileName = """${url}/ssb/sf1/${tableName}.tbl.gz"""
+ }
+ sql """ DROP TABLE IF EXISTS $tableName """
+ sql new File("""${context.file.parent}/ddl/${tableName}_sequence_create.sql""").text
+ streamLoad {
+ table tableName
+ set 'column_separator', '|'
+ set 'compress_type', 'GZ'
+ set 'columns', rows[0]
+ set 'function_column.sequence_col', rows[2]
+ file fileName
+
+ time 10000 // limit inflight 10s
+
+ // stream load action will check result, include Success status, and NumberTotalRows == NumberLoadedRows
+
+ // if declared a check callback, the default check condition will ignore.
+ // So you must check all condition
+ check { result, exception, startTime, endTime ->
+ if (exception != null) {
+ throw exception
+ }
+ log.info("Stream load result: ${result}".toString())
+ def json = parseJson(result)
+ assertEquals("success", json.Status.toLowerCase())
+ assertEquals(json.NumberTotalRows, json.NumberLoadedRows)
+ assertTrue(json.NumberLoadedRows > 0 && json.LoadBytes > 0)
+ }
+ }
+ sql 'sync'
+ for (int i = 1; i <= 5; i++) {
+ def loadRowCount = sql "select count(1) from ${tableName}"
+ logger.info("select ${tableName} numbers: ${loadRowCount[0][0]}".toString())
+ assertTrue(loadRowCount[0][0] == rows[1])
+ }
+ sql new File("""${context.file.parent}/ddl/${tableName}_delete.sql""").text
+ for (int i = 1; i <= 5; i++) {
+ def loadRowCount = sql "select count(1) from ${tableName}"
+ logger.info("select ${tableName} numbers: ${loadRowCount[0][0]}".toString())
+ assertTrue(loadRowCount[0][0] == 0)
+ }
+ }
+}
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/customer_create.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/customer_create.sql
new file mode 100644
index 0000000000..d172400d82
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/customer_create.sql
@@ -0,0 +1,16 @@
+CREATE TABLE IF NOT EXISTS `customer` (
+ `c_custkey` int(11) NOT NULL COMMENT "",
+ `c_name` varchar(26) NOT NULL COMMENT "",
+ `c_address` varchar(41) NOT NULL COMMENT "",
+ `c_city` varchar(11) NOT NULL COMMENT "",
+ `c_nation` varchar(16) NOT NULL COMMENT "",
+ `c_region` varchar(13) NOT NULL COMMENT "",
+ `c_phone` varchar(16) NOT NULL COMMENT "",
+ `c_mktsegment` varchar(11) NOT NULL COMMENT ""
+)
+UNIQUE KEY (`c_custkey`)
+DISTRIBUTED BY HASH(`c_custkey`) BUCKETS 10
+PROPERTIES (
+"compression"="zstd",
+"replication_num" = "1"
+);
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/customer_delete.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/customer_delete.sql
new file mode 100644
index 0000000000..fe22a226fe
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/customer_delete.sql
@@ -0,0 +1 @@
+truncate table customer;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/date_create.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/date_create.sql
new file mode 100644
index 0000000000..830ce3ce59
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/date_create.sql
@@ -0,0 +1,25 @@
+CREATE TABLE IF NOT EXISTS `date` (
+ `d_datekey` int(11) NOT NULL COMMENT "",
+ `d_date` varchar(20) NOT NULL COMMENT "",
+ `d_dayofweek` varchar(10) NOT NULL COMMENT "",
+ `d_month` varchar(11) NOT NULL COMMENT "",
+ `d_year` int(11) NOT NULL COMMENT "",
+ `d_yearmonthnum` int(11) NOT NULL COMMENT "",
+ `d_yearmonth` varchar(9) NOT NULL COMMENT "",
+ `d_daynuminweek` int(11) NOT NULL COMMENT "",
+ `d_daynuminmonth` int(11) NOT NULL COMMENT "",
+ `d_daynuminyear` int(11) NOT NULL COMMENT "",
+ `d_monthnuminyear` int(11) NOT NULL COMMENT "",
+ `d_weeknuminyear` int(11) NOT NULL COMMENT "",
+ `d_sellingseason` varchar(14) NOT NULL COMMENT "",
+ `d_lastdayinweekfl` int(11) NOT NULL COMMENT "",
+ `d_lastdayinmonthfl` int(11) NOT NULL COMMENT "",
+ `d_holidayfl` int(11) NOT NULL COMMENT "",
+ `d_weekdayfl` int(11) NOT NULL COMMENT ""
+)
+UNIQUE KEY (`d_datekey`)
+DISTRIBUTED BY HASH(`d_datekey`) BUCKETS 1
+PROPERTIES (
+"compression"="zstd",
+"replication_num" = "1"
+);
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/date_delete.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/date_delete.sql
new file mode 100644
index 0000000000..12933cbbad
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/date_delete.sql
@@ -0,0 +1 @@
+truncate table `date`;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/lineorder_create.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/lineorder_create.sql
new file mode 100644
index 0000000000..d75a3f1ae3
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/lineorder_create.sql
@@ -0,0 +1,33 @@
+CREATE TABLE IF NOT EXISTS `lineorder` (
+ `lo_orderdate` int(11) NOT NULL COMMENT "",
+ `lo_orderkey` bigint(20) NOT NULL COMMENT "",
+ `lo_linenumber` bigint(20) NOT NULL COMMENT "",
+ `lo_custkey` int(11) NOT NULL COMMENT "",
+ `lo_partkey` int(11) NOT NULL COMMENT "",
+ `lo_suppkey` int(11) NOT NULL COMMENT "",
+ `lo_orderpriority` varchar(16) NOT NULL COMMENT "",
+ `lo_shippriority` int(11) NOT NULL COMMENT "",
+ `lo_quantity` bigint(20) NOT NULL COMMENT "",
+ `lo_extendedprice` bigint(20) NOT NULL COMMENT "",
+ `lo_ordtotalprice` bigint(20) NOT NULL COMMENT "",
+ `lo_discount` bigint(20) NOT NULL COMMENT "",
+ `lo_revenue` bigint(20) NOT NULL COMMENT "",
+ `lo_supplycost` bigint(20) NOT NULL COMMENT "",
+ `lo_tax` bigint(20) NOT NULL COMMENT "",
+ `lo_commitdate` bigint(20) NOT NULL COMMENT "",
+ `lo_shipmode` varchar(11) NOT NULL COMMENT ""
+)
+UNIQUE KEY (`lo_orderdate`,`lo_orderkey`,`lo_linenumber`)
+PARTITION BY RANGE(`lo_orderdate`)
+(PARTITION p1992 VALUES [("-2147483648"), ("19930101")),
+PARTITION p1993 VALUES [("19930101"), ("19940101")),
+PARTITION p1994 VALUES [("19940101"), ("19950101")),
+PARTITION p1995 VALUES [("19950101"), ("19960101")),
+PARTITION p1996 VALUES [("19960101"), ("19970101")),
+PARTITION p1997 VALUES [("19970101"), ("19980101")),
+PARTITION p1998 VALUES [("19980101"), ("19990101")))
+DISTRIBUTED BY HASH(`lo_orderkey`) BUCKETS 48
+PROPERTIES (
+"compression"="zstd",
+"replication_num" = "1"
+);
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/lineorder_delete.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/lineorder_delete.sql
new file mode 100644
index 0000000000..329e040060
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/lineorder_delete.sql
@@ -0,0 +1 @@
+truncate table lineorder;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/part_create.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/part_create.sql
new file mode 100644
index 0000000000..becc59157c
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/part_create.sql
@@ -0,0 +1,17 @@
+CREATE TABLE IF NOT EXISTS `part` (
+ `p_partkey` int(11) NOT NULL COMMENT "",
+ `p_name` varchar(23) NOT NULL COMMENT "",
+ `p_mfgr` varchar(7) NOT NULL COMMENT "",
+ `p_category` varchar(8) NOT NULL COMMENT "",
+ `p_brand` varchar(10) NOT NULL COMMENT "",
+ `p_color` varchar(12) NOT NULL COMMENT "",
+ `p_type` varchar(26) NOT NULL COMMENT "",
+ `p_size` int(11) NOT NULL COMMENT "",
+ `p_container` varchar(11) NOT NULL COMMENT ""
+)
+UNIQUE KEY (`p_partkey`)
+DISTRIBUTED BY HASH(`p_partkey`) BUCKETS 10
+PROPERTIES (
+"compression"="zstd",
+"replication_num" = "1"
+);
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/part_delete.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/part_delete.sql
new file mode 100644
index 0000000000..02c6abd253
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/part_delete.sql
@@ -0,0 +1 @@
+truncate table `part`;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/supplier_create.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/supplier_create.sql
new file mode 100644
index 0000000000..7839462196
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/supplier_create.sql
@@ -0,0 +1,15 @@
+CREATE TABLE IF NOT EXISTS `supplier` (
+ `s_suppkey` int(11) NOT NULL COMMENT "",
+ `s_name` varchar(26) NOT NULL COMMENT "",
+ `s_address` varchar(26) NOT NULL COMMENT "",
+ `s_city` varchar(11) NOT NULL COMMENT "",
+ `s_nation` varchar(16) NOT NULL COMMENT "",
+ `s_region` varchar(13) NOT NULL COMMENT "",
+ `s_phone` varchar(16) NOT NULL COMMENT ""
+)
+UNIQUE KEY (`s_suppkey`)
+DISTRIBUTED BY HASH(`s_suppkey`) BUCKETS 10
+PROPERTIES (
+"compression"="zstd",
+"replication_num" = "1"
+);
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/supplier_delete.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/supplier_delete.sql
new file mode 100644
index 0000000000..39e663134c
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/ddl/supplier_delete.sql
@@ -0,0 +1 @@
+truncate table `supplier`;
\ No newline at end of file
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/load.groovy b/regression-test/suites/ssb_sf1_unique_sql_zstd/load.groovy
new file mode 100644
index 0000000000..db7104cf8e
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/load.groovy
@@ -0,0 +1,86 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements. See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership. The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied. See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+// Most of the cases are copied from https://github.com/trinodb/trino/tree/master
+// /testing/trino-product-tests/src/main/resources/sql-tests/testcases
+// and modified by Doris.
+
+// Note: To filter out tables from sql files, use the following one-liner comamnd
+// sed -nr 's/.*tables: (.*)$/\1/gp' /path/to/*.sql | sed -nr 's/,/\n/gp' | sort | uniq
+suite("load") {
+ def url = "https://doris-community-test-1308700295.cos.ap-hongkong.myqcloud.com"
+ def tables = ["customer", "lineorder", "part", "date", "supplier"]
+ def columns = ["""c_custkey,c_name,c_address,c_city,c_nation,c_region,c_phone,c_mktsegment,no_use""",
+ """lo_orderkey,lo_linenumber,lo_custkey,lo_partkey,lo_suppkey,lo_orderdate,lo_orderpriority,
+ lo_shippriority,lo_quantity,lo_extendedprice,lo_ordtotalprice,lo_discount,
+ lo_revenue,lo_supplycost,lo_tax,lo_commitdate,lo_shipmode,lo_dummy""",
+ """p_partkey,p_name,p_mfgr,p_category,p_brand,p_color,p_type,p_size,p_container,p_dummy""",
+ """d_datekey,d_date,d_dayofweek,d_month,d_year,d_yearmonthnum,d_yearmonth,
+ d_daynuminweek,d_daynuminmonth,d_daynuminyear,d_monthnuminyear,d_weeknuminyear,
+ d_sellingseason,d_lastdayinweekfl,d_lastdayinmonthfl,d_holidayfl,d_weekdayfl,d_dummy""",
+ """s_suppkey,s_name,s_address,s_city,s_nation,s_region,s_phone,s_dummy"""]
+
+ for (String table in tables) {
+ sql new File("""${context.file.parent}/ddl/${table}_create.sql""").text
+ sql new File("""${context.file.parent}/ddl/${table}_delete.sql""").text
+ }
+ i = 0
+ for (String tableName in tables) {
+ String fileName = """${context.sf1DataPath}/ssb/sf1/${tableName}.tbl.gz"""
+ if (!new File(fileName).isAbsolute()) {
+ fileName = new File(context.dataPath, fileName).getAbsolutePath()
+ }
+ if (!new File(fileName).exists()) {
+ fileName = """${url}/ssb/sf1/${tableName}.tbl.gz"""
+ }
+ streamLoad {
+ // a default db 'regression_test' is specified in
+ // ${DORIS_HOME}/conf/regression-conf.groovy
+ table tableName
+
+ // default label is UUID:
+ // set 'label' UUID.randomUUID().toString()
+
+ // default column_separator is specify in doris fe config, usually is '\t'.
+ // this line change to ','
+ set 'column_separator', '|'
+ set 'compress_type', 'GZ'
+ set 'columns', columns[i]
+ // relate to ${DORIS_HOME}/regression-test/data/demo/streamload_input.csv.
+ // also, you can stream load a http stream, e.g. http://xxx/some.csv
+ file fileName
+
+ time 10000 // limit inflight 10s
+
+ // stream load action will check result, include Success status, and NumberTotalRows == NumberLoadedRows
+
+ // if declared a check callback, the default check condition will ignore.
+ // So you must check all condition
+ check { result, exception, startTime, endTime ->
+ if (exception != null) {
+ throw exception
+ }
+ log.info("Stream load result: ${result}".toString())
+ def json = parseJson(result)
+ assertEquals("success", json.Status.toLowerCase())
+ assertEquals(json.NumberTotalRows, json.NumberLoadedRows)
+ assertTrue(json.NumberLoadedRows > 0 && json.LoadBytes > 0)
+ }
+ }
+ i++
+ }
+}
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q1.1.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q1.1.sql
new file mode 100644
index 0000000000..4ef15e93ea
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q1.1.sql
@@ -0,0 +1,24 @@
+-- Licensed to the Apache Software Foundation (ASF) under one
+-- or more contributor license agreements. See the NOTICE file
+-- distributed with this work for additional information
+-- regarding copyright ownership. The ASF licenses this file
+-- to you under the Apache License, Version 2.0 (the
+-- "License"); you may not use this file except in compliance
+-- with the License. You may obtain a copy of the License at
+--
+-- http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing,
+-- software distributed under the License is distributed on an
+-- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+-- KIND, either express or implied. See the License for the
+-- specific language governing permissions and limitations
+-- under the License.
+
+SELECT SUM(lo_extendedprice*lo_discount) AS
+REVENUE
+FROM lineorder, date
+WHERE lo_orderdate = d_datekey
+AND d_year = 1993
+AND lo_discount BETWEEN 1 AND 3
+AND lo_quantity < 25;
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q1.2.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q1.2.sql
new file mode 100644
index 0000000000..1b8442bd93
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q1.2.sql
@@ -0,0 +1,24 @@
+-- Licensed to the Apache Software Foundation (ASF) under one
+-- or more contributor license agreements. See the NOTICE file
+-- distributed with this work for additional information
+-- regarding copyright ownership. The ASF licenses this file
+-- to you under the Apache License, Version 2.0 (the
+-- "License"); you may not use this file except in compliance
+-- with the License. You may obtain a copy of the License at
+--
+-- http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing,
+-- software distributed under the License is distributed on an
+-- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+-- KIND, either express or implied. See the License for the
+-- specific language governing permissions and limitations
+-- under the License.
+
+SELECT SUM(lo_extendedprice*lo_discount) AS
+REVENUE
+FROM lineorder, date
+WHERE lo_orderdate = d_datekey
+AND d_yearmonth = 'Jan1994'
+AND lo_discount BETWEEN 4 AND 6
+AND lo_quantity BETWEEN 26 AND 35;
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q1.3.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q1.3.sql
new file mode 100644
index 0000000000..ed6e51b1cf
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q1.3.sql
@@ -0,0 +1,25 @@
+-- Licensed to the Apache Software Foundation (ASF) under one
+-- or more contributor license agreements. See the NOTICE file
+-- distributed with this work for additional information
+-- regarding copyright ownership. The ASF licenses this file
+-- to you under the Apache License, Version 2.0 (the
+-- "License"); you may not use this file except in compliance
+-- with the License. You may obtain a copy of the License at
+--
+-- http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing,
+-- software distributed under the License is distributed on an
+-- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+-- KIND, either express or implied. See the License for the
+-- specific language governing permissions and limitations
+-- under the License.
+
+SELECT SUM(lo_extendedprice*lo_discount) AS
+REVENUE
+FROM lineorder, date
+WHERE lo_orderdate = d_datekey
+AND d_weeknuminyear= 6
+AND d_year = 1994
+AND lo_discount BETWEEN 5 AND 7
+AND lo_quantity BETWEEN 26 AND 35;
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q2.1.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q2.1.sql
new file mode 100644
index 0000000000..e1a1f52d18
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q2.1.sql
@@ -0,0 +1,26 @@
+-- Licensed to the Apache Software Foundation (ASF) under one
+-- or more contributor license agreements. See the NOTICE file
+-- distributed with this work for additional information
+-- regarding copyright ownership. The ASF licenses this file
+-- to you under the Apache License, Version 2.0 (the
+-- "License"); you may not use this file except in compliance
+-- with the License. You may obtain a copy of the License at
+--
+-- http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing,
+-- software distributed under the License is distributed on an
+-- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+-- KIND, either express or implied. See the License for the
+-- specific language governing permissions and limitations
+-- under the License.
+
+SELECT SUM(lo_revenue), d_year, p_brand
+FROM lineorder, date, part, supplier
+WHERE lo_orderdate = d_datekey
+AND lo_partkey = p_partkey
+AND lo_suppkey = s_suppkey
+AND p_category = 'MFGR#12'
+AND s_region = 'AMERICA'
+GROUP BY d_year, p_brand
+ORDER BY d_year, p_brand;
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q2.2.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q2.2.sql
new file mode 100644
index 0000000000..3db6170119
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q2.2.sql
@@ -0,0 +1,27 @@
+-- Licensed to the Apache Software Foundation (ASF) under one
+-- or more contributor license agreements. See the NOTICE file
+-- distributed with this work for additional information
+-- regarding copyright ownership. The ASF licenses this file
+-- to you under the Apache License, Version 2.0 (the
+-- "License"); you may not use this file except in compliance
+-- with the License. You may obtain a copy of the License at
+--
+-- http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing,
+-- software distributed under the License is distributed on an
+-- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+-- KIND, either express or implied. See the License for the
+-- specific language governing permissions and limitations
+-- under the License.
+
+SELECT SUM(lo_revenue), d_year, p_brand
+FROM lineorder, date, part, supplier
+WHERE lo_orderdate = d_datekey
+AND lo_partkey = p_partkey
+AND lo_suppkey = s_suppkey
+AND p_brand BETWEEN 'MFGR#2221'
+AND 'MFGR#2228'
+AND s_region = 'ASIA'
+GROUP BY d_year, p_brand
+ORDER BY d_year, p_brand;
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q2.3.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q2.3.sql
new file mode 100644
index 0000000000..b70ca90666
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q2.3.sql
@@ -0,0 +1,26 @@
+-- Licensed to the Apache Software Foundation (ASF) under one
+-- or more contributor license agreements. See the NOTICE file
+-- distributed with this work for additional information
+-- regarding copyright ownership. The ASF licenses this file
+-- to you under the Apache License, Version 2.0 (the
+-- "License"); you may not use this file except in compliance
+-- with the License. You may obtain a copy of the License at
+--
+-- http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing,
+-- software distributed under the License is distributed on an
+-- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+-- KIND, either express or implied. See the License for the
+-- specific language governing permissions and limitations
+-- under the License.
+
+SELECT SUM(lo_revenue), d_year, p_brand
+FROM lineorder, date, part, supplier
+WHERE lo_orderdate = d_datekey
+AND lo_partkey = p_partkey
+AND lo_suppkey = s_suppkey
+AND p_brand = 'MFGR#2239'
+AND s_region = 'EUROPE'
+GROUP BY d_year, p_brand
+ORDER BY d_year, p_brand;
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q3.1.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q3.1.sql
new file mode 100644
index 0000000000..70f17d789b
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q3.1.sql
@@ -0,0 +1,28 @@
+-- Licensed to the Apache Software Foundation (ASF) under one
+-- or more contributor license agreements. See the NOTICE file
+-- distributed with this work for additional information
+-- regarding copyright ownership. The ASF licenses this file
+-- to you under the Apache License, Version 2.0 (the
+-- "License"); you may not use this file except in compliance
+-- with the License. You may obtain a copy of the License at
+--
+-- http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing,
+-- software distributed under the License is distributed on an
+-- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+-- KIND, either express or implied. See the License for the
+-- specific language governing permissions and limitations
+-- under the License.
+
+SELECT c_nation, s_nation, d_year,
+SUM(lo_revenue) AS REVENUE
+FROM customer, lineorder, supplier, date
+WHERE lo_custkey = c_custkey
+AND lo_suppkey = s_suppkey
+AND lo_orderdate = d_datekey
+AND c_region = 'ASIA'
+AND s_region = 'ASIA'
+AND d_year >= 1992 AND d_year <= 1997
+GROUP BY c_nation, s_nation, d_year
+ORDER BY d_year ASC, REVENUE DESC;
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q3.2.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q3.2.sql
new file mode 100644
index 0000000000..a416fbea8b
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q3.2.sql
@@ -0,0 +1,28 @@
+-- Licensed to the Apache Software Foundation (ASF) under one
+-- or more contributor license agreements. See the NOTICE file
+-- distributed with this work for additional information
+-- regarding copyright ownership. The ASF licenses this file
+-- to you under the Apache License, Version 2.0 (the
+-- "License"); you may not use this file except in compliance
+-- with the License. You may obtain a copy of the License at
+--
+-- http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing,
+-- software distributed under the License is distributed on an
+-- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+-- KIND, either express or implied. See the License for the
+-- specific language governing permissions and limitations
+-- under the License.
+
+SELECT c_city, s_city, d_year, sum(lo_revenue)
+AS REVENUE
+FROM customer, lineorder, supplier, date
+WHERE lo_custkey = c_custkey
+AND lo_suppkey = s_suppkey
+AND lo_orderdate = d_datekey
+AND c_nation = 'UNITED STATES'
+AND s_nation = 'UNITED STATES'
+AND d_year >= 1992 AND d_year <= 1997
+GROUP BY c_city, s_city, d_year
+ORDER BY d_year ASC, REVENUE DESC;
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q3.3.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q3.3.sql
new file mode 100644
index 0000000000..98e29b72e7
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q3.3.sql
@@ -0,0 +1,30 @@
+-- Licensed to the Apache Software Foundation (ASF) under one
+-- or more contributor license agreements. See the NOTICE file
+-- distributed with this work for additional information
+-- regarding copyright ownership. The ASF licenses this file
+-- to you under the Apache License, Version 2.0 (the
+-- "License"); you may not use this file except in compliance
+-- with the License. You may obtain a copy of the License at
+--
+-- http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing,
+-- software distributed under the License is distributed on an
+-- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+-- KIND, either express or implied. See the License for the
+-- specific language governing permissions and limitations
+-- under the License.
+
+SELECT c_city, s_city, d_year, SUM(lo_revenue)
+AS REVENUE
+FROM customer, lineorder, supplier, date
+WHERE lo_custkey = c_custkey
+AND lo_suppkey = s_suppkey
+AND lo_orderdate = d_datekey
+AND (c_city='UNITED KI1'
+OR c_city='UNITED KI5')
+AND (s_city='UNITED KI1'
+OR s_city='UNITED KI5')
+AND d_year >= 1992 AND d_year <= 1997
+GROUP BY c_city, s_city, d_year
+ORDER BY d_year ASC, REVENUE DESC;
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q3.4.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q3.4.sql
new file mode 100644
index 0000000000..65fe992ca4
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q3.4.sql
@@ -0,0 +1,30 @@
+-- Licensed to the Apache Software Foundation (ASF) under one
+-- or more contributor license agreements. See the NOTICE file
+-- distributed with this work for additional information
+-- regarding copyright ownership. The ASF licenses this file
+-- to you under the Apache License, Version 2.0 (the
+-- "License"); you may not use this file except in compliance
+-- with the License. You may obtain a copy of the License at
+--
+-- http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing,
+-- software distributed under the License is distributed on an
+-- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+-- KIND, either express or implied. See the License for the
+-- specific language governing permissions and limitations
+-- under the License.
+
+SELECT c_city, s_city, d_year, SUM(lo_revenue)
+AS REVENUE
+FROM customer, lineorder, supplier, date
+WHERE lo_custkey = c_custkey
+AND lo_suppkey = s_suppkey
+AND lo_orderdate = d_datekey
+AND (c_city='UNITED KI1'
+OR c_city='UNITED KI5')
+AND (s_city='UNITED KI1'
+OR s_city='UNITED KI5')
+AND d_yearmonth = 'Dec1997'
+GROUP BY c_city, s_city, d_year
+ORDER BY d_year ASC, REVENUE DESC;
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q4.1.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q4.1.sql
new file mode 100644
index 0000000000..bdcd730bf9
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q4.1.sql
@@ -0,0 +1,30 @@
+-- Licensed to the Apache Software Foundation (ASF) under one
+-- or more contributor license agreements. See the NOTICE file
+-- distributed with this work for additional information
+-- regarding copyright ownership. The ASF licenses this file
+-- to you under the Apache License, Version 2.0 (the
+-- "License"); you may not use this file except in compliance
+-- with the License. You may obtain a copy of the License at
+--
+-- http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing,
+-- software distributed under the License is distributed on an
+-- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+-- KIND, either express or implied. See the License for the
+-- specific language governing permissions and limitations
+-- under the License.
+
+SELECT d_year, c_nation,
+SUM(lo_revenue - lo_supplycost) AS PROFIT
+FROM date, customer, supplier, part, lineorder
+WHERE lo_custkey = c_custkey
+AND lo_suppkey = s_suppkey
+AND lo_partkey = p_partkey
+AND lo_orderdate = d_datekey
+AND c_region = 'AMERICA'
+AND s_region = 'AMERICA'
+AND (p_mfgr = 'MFGR#1'
+OR p_mfgr = 'MFGR#2')
+GROUP BY d_year, c_nation
+ORDER BY d_year, c_nation;
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q4.2.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q4.2.sql
new file mode 100644
index 0000000000..24c82cf682
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q4.2.sql
@@ -0,0 +1,31 @@
+-- Licensed to the Apache Software Foundation (ASF) under one
+-- or more contributor license agreements. See the NOTICE file
+-- distributed with this work for additional information
+-- regarding copyright ownership. The ASF licenses this file
+-- to you under the Apache License, Version 2.0 (the
+-- "License"); you may not use this file except in compliance
+-- with the License. You may obtain a copy of the License at
+--
+-- http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing,
+-- software distributed under the License is distributed on an
+-- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+-- KIND, either express or implied. See the License for the
+-- specific language governing permissions and limitations
+-- under the License.
+
+SELECT d_year, s_nation, p_category,
+SUM(lo_revenue - lo_supplycost) AS PROFIT
+FROM date, customer, supplier, part, lineorder
+WHERE lo_custkey = c_custkey
+AND lo_suppkey = s_suppkey
+AND lo_partkey = p_partkey
+AND lo_orderdate = d_datekey
+AND c_region = 'AMERICA'
+AND s_region = 'AMERICA'
+AND (d_year = 1997 OR d_year = 1998)
+AND (p_mfgr = 'MFGR#1'
+OR p_mfgr = 'MFGR#2')
+GROUP BY d_year, s_nation, p_category
+ORDER BY d_year, s_nation, p_category;
diff --git a/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q4.3.sql b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q4.3.sql
new file mode 100644
index 0000000000..0dcc08bd26
--- /dev/null
+++ b/regression-test/suites/ssb_sf1_unique_sql_zstd/sql/q4.3.sql
@@ -0,0 +1,29 @@
+-- Licensed to the Apache Software Foundation (ASF) under one
+-- or more contributor license agreements. See the NOTICE file
+-- distributed with this work for additional information
+-- regarding copyright ownership. The ASF licenses this file
+-- to you under the Apache License, Version 2.0 (the
+-- "License"); you may not use this file except in compliance
+-- with the License. You may obtain a copy of the License at
+--
+-- http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing,
+-- software distributed under the License is distributed on an
+-- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+-- KIND, either express or implied. See the License for the
+-- specific language governing permissions and limitations
+-- under the License.
+
+SELECT d_year, s_city, p_brand,
+SUM(lo_revenue - lo_supplycost) AS PROFIT
+FROM date, customer, supplier, part, lineorder
+WHERE lo_custkey = c_custkey
+AND lo_suppkey = s_suppkey
+AND lo_partkey = p_partkey
+AND lo_orderdate = d_datekey
+AND s_nation = 'UNITED STATES'
+AND (d_year = 1997 OR d_year = 1998)
+AND p_category = 'MFGR#14'
+GROUP BY d_year, s_city, p_brand
+ORDER BY d_year, s_city, p_brand;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org