[enhancement](test) add tpch_sf100_unique p2 test (#12697)
This commit is contained in:
Yongqiang YANG
@ -0,0 +1,5 @@
|
||||
-- !q01 --
|
||||
A F 3775127758.00 5660776097194.45 5377736398183.9374 5592847429515.927026 25.50 38236.12 0.05 148047881
|
||||
N F 98553062.00 147771098385.98 140384965965.0348 145999793032.775829 25.50 38237.20 0.05 3864590
|
||||
N O 7436302976.00 11150725681373.59 10593195308234.8523 11016932248183.655467 25.50 38237.23 0.05 291619617
|
||||
R F 3775724970.00 5661603032745.34 5378513563915.4097 5593662252666.916161 25.50 38236.70 0.05 148067261
|
||||
101
regression-test/data/tpch_sf100_unique_sql_p2/sql/q02.out
Normal file
101
regression-test/data/tpch_sf100_unique_sql_p2/sql/q02.out
Normal file
@ -0,0 +1,101 @@
|
||||
-- !q02 --
|
||||
9999.70 Supplier#000239544 UNITED KINGDOM 6739531 Manufacturer#4 ,6oexY7ft68JKJCN1SQ LUO5Xf 33-509-584-9496 ets are. blithely special accounts wake across t
|
||||
9999.65 Supplier#000143654 FRANCE 2393647 Manufacturer#3 HhHCZ,RosE8He4uYvyIDqsPZe,7cZiJh1y9, 16-166-504-5864 special accounts. never dogged deposits
|
||||
9999.49 Supplier#000615014 GERMANY 12365001 Manufacturer#3 4C,uOuJDig7z,4e 17-780-902-4027 pinto beans affix along th
|
||||
9999.28 Supplier#000494480 ROMANIA 17244462 Manufacturer#3 hNB2qcYmnyeqrd em,o29TxzLwwrl 29-756-312-1779 ly. slyly final pains detect furiously qu
|
||||
9998.87 Supplier#000826281 ROMANIA 14326252 Manufacturer#3 LkGmLSAjbjgKS5ZRepL 29-775-451-4774 slyly silent accounts affix furiously across the final, even ideas; tithe
|
||||
9998.56 Supplier#000039514 UNITED KINGDOM 7539499 Manufacturer#2 fUN95rpikfiqeGo,okl,27ItSq9fMpr 33-317-828-7758 olites use about the blithely regular warhorses. carefully final instructions a
|
||||
9997.89 Supplier#000319666 RUSSIA 19319665 Manufacturer#1 SZtdx3rzXnFuiVuJzKathV9 32-972-151-6038 furiously ironic pearls. furiously regular foxes along the furiously
|
||||
9997.85 Supplier#000718770 ROMANIA 718769 Manufacturer#1 2173woKsCg7zpHCqhiEXFTmYYqpT4XONnRAsUryE 29-663-409-2865 posits sleep across the blithely express requests.
|
||||
9997.83 Supplier#000348318 FRANCE 9348317 Manufacturer#4 AvfnvjCFAg1aNpj 16-718-707-5676 e pending requests: furiously even deposits boost furiously slyly even requests.
|
||||
9997.73 Supplier#000329974 RUSSIA 4079969 Manufacturer#3 eKtIadopsE 32-268-488-7178 uickly. furiously ironic requests are slyly above the regula
|
||||
9997.46 Supplier#000906546 FRANCE 1406543 Manufacturer#2 aMZ13ITqaYCGwqW42qXJ92ho 16-249-122-4511 endencies above the furiously even
|
||||
9997.20 Supplier#000487664 FRANCE 2737657 Manufacturer#2 ShFSQYlV,8EvuNQkB7B 16-714-518-5435 mong the ideas. accounts poach p
|
||||
9997.17 Supplier#000123140 ROMANIA 5373124 Manufacturer#2 O80qPjM5qonzjxGI,ClSnI7Vf3dlZCztkNx3ho 29-567-411-4572 uriously slyly bold forges. slyly pending platelets haggle after the excuses. quickly pend
|
||||
9997.06 Supplier#000725417 GERMANY 10225396 Manufacturer#1 10iRwq3,LeyTjZx8G 17-577-582-2010 arefully dogged accounts. final, pending asymptote
|
||||
9996.45 Supplier#000795554 ROMANIA 14795553 Manufacturer#2 qRD x8 zsS 7n11Cu6uMJkgSDL2Pv 29-305-384-2702 instructions believe slyly i
|
||||
9995.96 Supplier#000566208 FRANCE 9816180 Manufacturer#5 RMnISVay,G0prBUAZ,yqqm7ftyZbjH0CfJyXP95 16-665-147-8314 mong the ironic requests caj
|
||||
9995.96 Supplier#000629520 FRANCE 13129493 Manufacturer#3 kjmenylD2Ut5JJxh1n8P1,cl,XqR 16-785-547-3814 foxes detect blithely. even, ironic courts a
|
||||
9995.93 Supplier#000388258 UNITED KINGDOM 6138251 Manufacturer#2 rUB88zGIucl73Jl4 33-829-188-2160 arefully express requests. pending, express pinto beans
|
||||
9995.79 Supplier#000998425 FRANCE 248424 Manufacturer#4 tjoKE1Srnp3l9lpwSP40nMonOOM7F2fa 16-228-926-9937 ding foxes haggle fluffily. carefully ironic ideas
|
||||
9995.42 Supplier#000220794 ROMANIA 12470757 Manufacturer#1 kwxtCRMG9VWfJ75Sij2K 29-557-942-9023 . carefully pending platelets haggle after the final, regular packa
|
||||
9995.35 Supplier#000660115 RUSSIA 14660114 Manufacturer#4 FeZEq,FUk4Zb5QcPt8A7Eb9iD28 32-485-807-8645 al, quick asymptotes atop the furiously bold pinto beans cajole among the even, final packages. ca
|
||||
9995.34 Supplier#000190688 UNITED KINGDOM 13440648 Manufacturer#2 pSlhz0825vaM,Ly8Y4VLCtdGzFNpsDh35U 33-424-942-1566 side of the carefully special pinto
|
||||
9995.10 Supplier#000885436 UNITED KINGDOM 17885435 Manufacturer#1 ,UjzLIKv09CxBgxq61QeGIQO4uVDu9sHgad 33-504-226-2765 theodolites. permanently ironi
|
||||
9995.07 Supplier#000490282 ROMANIA 12740245 Manufacturer#4 JgPB99IeBLB 29-394-304-4131 efully final requests after the even accounts serve against the slyly
|
||||
9994.85 Supplier#000581928 GERMANY 2831921 Manufacturer#1 UbBVSalX1YIGla9W564VvUVr9F8a83qdz 17-230-642-6940 e evenly slyly special asymptotes. blithely pending packages cajole slyly unusu
|
||||
9994.66 Supplier#000071807 FRANCE 14821792 Manufacturer#5 ae0mc8V3kBT 16-407-922-3032 final packages haggle against the ironic ideas.
|
||||
9994.46 Supplier#000654651 RUSSIA 5404645 Manufacturer#4 UNJ0VtaR0myKMfTPUTfSKPlDIYXaW 32-280-208-7451 e quiet foxes. blithely ironic accounts boost. deposits cajole closely. final, regular account
|
||||
9994.15 Supplier#000750884 UNITED KINGDOM 4000871 Manufacturer#3 SWcsreqT8bNyEl9l8Ggk4EmJBBATWmC6l98cUT4 33-640-820-7791 e regularly pending warhorses. fluffily ironic packages are around the sa
|
||||
9994.15 Supplier#000750884 UNITED KINGDOM 4250875 Manufacturer#3 SWcsreqT8bNyEl9l8Ggk4EmJBBATWmC6l98cUT4 33-640-820-7791 e regularly pending warhorses. fluffily ironic packages are around the sa
|
||||
9994.11 Supplier#000213298 FRANCE 11963286 Manufacturer#5 hZZeJWYgWwVdN G9dv,8 16-813-605-2602 f the furiously unusual foxes? carefully final ideas are final, pending accoun
|
||||
9993.91 Supplier#000674336 RUSSIA 14924293 Manufacturer#3 sWWhoA PgexaLtzhymjq2h,2gzZ 32-949-587-4877 ously even dependencies eat blithely carefully even ideas? slyly final asymptotes ca
|
||||
9993.58 Supplier#000597447 UNITED KINGDOM 9097428 Manufacturer#4 3XzB0uNECeGW0ffaQP 33-986-148-2564 ully final deposits. slyly final dinos cajole quickly.
|
||||
9993.21 Supplier#000935931 UNITED KINGDOM 7935930 Manufacturer#1 0LoRZEdAtXK2xnXUU 33-117-102-3544 ntain blithely silent instructions. unusual, final foxes s
|
||||
9993.21 Supplier#000935931 UNITED KINGDOM 11435908 Manufacturer#2 0LoRZEdAtXK2xnXUU 33-117-102-3544 ntain blithely silent instructions. unusual, final foxes s
|
||||
9992.71 Supplier#000401090 GERMANY 11401089 Manufacturer#1 vewBOaiUo4O5dGA5uHVP1pcPxpk 17-358-630-1671 ar dolphins. forges should are slyly special foxes. instruct
|
||||
9992.70 Supplier#000245718 UNITED KINGDOM 12745693 Manufacturer#1 7MPFsvp97N6X0 33-570-729-4176 carefully above the blithely special pearls. silen
|
||||
9992.65 Supplier#000611657 UNITED KINGDOM 7611656 Manufacturer#3 ohGbzxVugfP8lBMRJ 33-456-959-4171 as wake blithely according to the fluffily unusual accounts
|
||||
9991.82 Supplier#000754421 GERMANY 3504417 Manufacturer#2 Jg6ETXggGL8tfX 17-908-303-8190 ost slyly. carefully bold deposits use furiously around the slyly regul
|
||||
9991.77 Supplier#000514042 ROMANIA 1014039 Manufacturer#1 ND8g73JbcuugDphHmWqxNV,oBDDyUJjYpR8snJ 29-100-282-1954 ave to affix furiously. special asymptotes about the ironic foxes sleep qui
|
||||
9991.03 Supplier#000403268 FRANCE 4403267 Manufacturer#4 jq82,CMMJ854nhPHxI,VgsCcM5cE9D84y 16-970-984-3812 es. carefully ironic foxes sleep furiously. regular requests wake slyly f
|
||||
9990.81 Supplier#000106044 ROMANIA 7106043 Manufacturer#3 EtY0 A0NcTgxOw 4QtUysJm8xsTU7 29-217-664-9441 ve the bold foxes. quickly regular dependencies
|
||||
9990.65 Supplier#000661325 RUSSIA 5411319 Manufacturer#4 Jqvf7BMv3Q 32-312-563-2260 le under the bold accounts. quickly ironic requests wake blithe
|
||||
9990.32 Supplier#000985253 FRANCE 13735239 Manufacturer#1 CFBZCvRZrEColmOxcK9Jc6Y8, Sz 8Wpg7Uy 16-848-482-4079 ffily regular excuses. silent, stealthy packages wake quickly ag
|
||||
9990.13 Supplier#000138240 FRANCE 1888238 Manufacturer#4 nOOS2ksL4euund3hoZfGvFj6LiiUl8v,GRInYEqP 16-206-608-6166 lar requests. pending foxes at the carefully final accounts haggle slyly under
|
||||
9990.03 Supplier#000081720 UNITED KINGDOM 17581685 Manufacturer#4 9p,sDTmwbliPlu0EwiOvXHT1maCt 33-166-373-3036 unwind fluffily about the bold pinto beans. silent packages are acco
|
||||
9989.93 Supplier#000500883 FRANCE 6000870 Manufacturer#1 qwYWO7O8l7IWxU,Wy3ZsN 16-736-685-5763 kly enticing accounts haggle furiously according to the ir
|
||||
9989.46 Supplier#000625093 RUSSIA 15875047 Manufacturer#3 Z7zj GJZH9xGed36C1a7KwYH 32-291-695-4022 the pinto beans wake blithely furious, regular somas.
|
||||
9988.59 Supplier#000496415 UNITED KINGDOM 10746384 Manufacturer#3 LEscFxfnTFNS 33-577-453-5087 o the furiously special foxes are furiously above the furiously r
|
||||
9988.49 Supplier#000436244 RUSSIA 18436243 Manufacturer#5 7ZeIA2ClR9QbU sl,dA 32-837-886-1052 affix according to the accounts. slyly regular platelets nag car
|
||||
9988.40 Supplier#000465785 GERMANY 11715751 Manufacturer#1 FTnx Wxs7TvUd 17-981-295-1619 pendencies are closely ironic pinto beans. special requests boost carefully
|
||||
9988.29 Supplier#000273304 ROMANIA 3273303 Manufacturer#4 rVw7T,PbkYA35J, 29-238-280-6619 r accounts. fluffily ironic foxes against the carefully eve
|
||||
9988.23 Supplier#000834777 ROMANIA 6334764 Manufacturer#2 F71Lhq4ZQoxSQZ4224PixZKe 29-851-710-7841 usly pending packages affix busy sentiments. furiou
|
||||
9987.75 Supplier#000424377 FRANCE 13174363 Manufacturer#5 YrfGEo2QyqNv1mLnz0zCzS2BqBW7WXzJLva 16-246-384-2743 even requests thrash regularly regular deposits? unusual excuses integrate excuses. ironic grouches
|
||||
9987.51 Supplier#000020657 ROMANIA 5520646 Manufacturer#5 4pL,8BT3Yun,17QHqAr9 A,ZFyyuH4L 29-167-460-7830 otes. excuses behind the blithely regular packages are furio
|
||||
9987.47 Supplier#000193113 UNITED KINGDOM 12443076 Manufacturer#4 ED0uCnMITUb,VWsMpy,WEas 33-692-317-4143 of the blithely regular instructions. slyly regular excuses integrate blithe
|
||||
9987.30 Supplier#000355390 UNITED KINGDOM 15605344 Manufacturer#4 NIzKytEacSjE90sKNV GsCubHq16lVV3pwU2CglE 33-376-347-5270 blithely. special, final accounts haggle pe
|
||||
9987.03 Supplier#000170919 UNITED KINGDOM 5170918 Manufacturer#1 7pEflzA,Z,jatHSzNV 33-830-782-9233 nod evenly against the carefully sly accounts? ironic grouches around the furiously regular depo
|
||||
9986.90 Supplier#000980301 RUSSIA 14480272 Manufacturer#1 FIw6Hu4OTxx 32-748-246-3728 ial packages cajole quickly against the carefully final theodolites. furious
|
||||
9986.56 Supplier#000290709 FRANCE 12790684 Manufacturer#5 DMl,KyuqKyIR6ihi0 16-173-236-8921 blithely slyly regular ideas. finally final dependencies cajole abo
|
||||
9985.79 Supplier#000508791 UNITED KINGDOM 13258777 Manufacturer#1 btmR2gR43fl 33-814-455-4907 ons. dependencies cajole blithely. deposits nag blithely among the blith
|
||||
9985.78 Supplier#000248887 UNITED KINGDOM 12998874 Manufacturer#5 os,bXPqP1MGGFHkogMXtu50G1r9qz39isC7P5uP 33-358-738-5370 tructions. regular packages cajole careful
|
||||
9985.77 Supplier#000221145 FRANCE 19971125 Manufacturer#4 9U1ezsK3jUkkuWWR7Dm,i 16-648-985-3872 t notornis haggle slyly never final requ
|
||||
9985.54 Supplier#000147207 GERMANY 9647188 Manufacturer#1 rDqExccHg3IBN4k 17-345-679-3036 olites are carefully after the ironic instructi
|
||||
9985.54 Supplier#000147207 GERMANY 16397158 Manufacturer#2 rDqExccHg3IBN4k 17-345-679-3036 olites are carefully after the ironic instructi
|
||||
9984.95 Supplier#000888199 ROMANIA 5138183 Manufacturer#2 9Ueet9zZD4ImX1A6cIgxBX1bFoNeHR 29-392-570-4019 its. theodolites grow carefully. blithely express
|
||||
9984.88 Supplier#000171850 FRANCE 6421831 Manufacturer#4 j5xTAI7OSs4KDh1t,qwZkibgPOBO34Ps 16-530-650-3779 le fluffily between the carefully pending theodolites. courts sleep against the sl
|
||||
9984.88 Supplier#000171850 FRANCE 17671815 Manufacturer#2 j5xTAI7OSs4KDh1t,qwZkibgPOBO34Ps 16-530-650-3779 le fluffily between the carefully pending theodolites. courts sleep against the sl
|
||||
9984.35 Supplier#000990772 UNITED KINGDOM 17990771 Manufacturer#3 dDc8gq8eHodj0O4u1 33-312-861-1228 ully regular accounts. carefully even requests cajole express excuses. accounts across the packag
|
||||
9984.34 Supplier#000818625 GERMANY 12818624 Manufacturer#5 MOcARfNG6z 17-392-999-1881 s. sentiments nag slyly. carefully final multipliers cajole ca
|
||||
9983.77 Supplier#000807239 ROMANIA 6307226 Manufacturer#2 st0C61GJEI 29-870-782-8107 bove the blithely pending accounts. carefully ironic r
|
||||
9983.77 Supplier#000807239 ROMANIA 8057214 Manufacturer#4 st0C61GJEI 29-870-782-8107 bove the blithely pending accounts. carefully ironic r
|
||||
9983.74 Supplier#000682561 GERMANY 6682560 Manufacturer#3 c,IiDoPEFbhvSbJx1MoJGp2NEDYykjJSzETFZV 17-678-399-9268 ross the blithely even foxes cajole carefully even packages. slyly even accounts cajole slyly
|
||||
9983.32 Supplier#000856704 UNITED KINGDOM 10356683 Manufacturer#4 KqGZ VMRW7l3FJSy 33-265-376-9029 ial dependencies around the slyly fluffy dependencies affi
|
||||
9982.02 Supplier#000212153 RUSSIA 4712144 Manufacturer#3 18lzRWCE0T BNNN 32-353-256-5897 t fluffily. closely regular platelets integrate slyly above the final theodolites. regular, bold ac
|
||||
9981.72 Supplier#000823344 FRANCE 3823343 Manufacturer#1 9utnMuKlX7iXyMRL42fdOIEEB5TT94iJcS09P9 16-555-293-2838 warthogs. ironic accounts
|
||||
9981.10 Supplier#000343979 ROMANIA 19843940 Manufacturer#5 2M4nHXrC vKzmL8kq0Ph8oVnLQ 29-231-383-6316 c requests nag always furiously even deposits. carefully enticing accounts wak
|
||||
9980.93 Supplier#000118263 UNITED KINGDOM 3118262 Manufacturer#2 U8WUFu5rph 33-156-772-3541 excuses cajole blithely furiously final attainmen
|
||||
9980.68 Supplier#000479583 RUSSIA 1479582 Manufacturer#2 QbExPtLu6K1I5SewUHV E7I Oc3K4HsrIvf NZ 32-217-607-1271 t, ironic dependencies nod
|
||||
9980.52 Supplier#000683362 ROMANIA 2933355 Manufacturer#5 QeU2Keqy3xLfg1DLhlhxelCFe1CMZo 29-387-482-2397 ithely. theodolites wake carefully aft
|
||||
9980.52 Supplier#000683362 ROMANIA 15933316 Manufacturer#3 QeU2Keqy3xLfg1DLhlhxelCFe1CMZo 29-387-482-2397 ithely. theodolites wake carefully aft
|
||||
9980.49 Supplier#000971427 ROMANIA 1221423 Manufacturer#2 zsZUpTpSY7beFw7PRIKhONjO9U,Z 29-714-548-4045 refully regular packages. deposits according to the foxes wake slowly closely final foxes.
|
||||
9979.50 Supplier#000458742 ROMANIA 9208732 Manufacturer#2 M4HpMW1n5hq9RymwNsUo 29-460-746-6456 ngly pending pinto beans. blithely pending patterns use sly
|
||||
9979.34 Supplier#000335566 ROMANIA 11335565 Manufacturer#4 SQKHTzKD7KpFrs 29-120-111-4388 lar accounts. furiously even platelets nag never. fina
|
||||
9979.04 Supplier#000966284 GERMANY 9216256 Manufacturer#4 256YX,9j7gRpvSHFcWnwJDSVFvpzD9nHS 17-946-544-5166 slyly brave accounts hagg
|
||||
9978.88 Supplier#000113445 FRANCE 12363408 Manufacturer#5 aWDYwr,56rL,gftEbiTj 16-261-874-6958 en ideas poach fluffily about the sile
|
||||
9978.82 Supplier#000221713 ROMANIA 19721674 Manufacturer#4 2hYyZXt17eehrimFq3S04abyUTfYvYINh 29-143-199-8338 ide of the fluffily express packages detect furiously throughout
|
||||
9978.78 Supplier#000118448 FRANCE 368447 Manufacturer#1 jz6uRKWsarM 7PlkE6MEAla8u 16-978-504-3922 its. quickly unusual accounts haggle quickly about the special deposits.
|
||||
9978.78 Supplier#000118448 FRANCE 1118447 Manufacturer#3 jz6uRKWsarM 7PlkE6MEAla8u 16-978-504-3922 its. quickly unusual accounts haggle quickly about the special deposits.
|
||||
9978.78 Supplier#000118448 FRANCE 12368411 Manufacturer#1 jz6uRKWsarM 7PlkE6MEAla8u 16-978-504-3922 its. quickly unusual accounts haggle quickly about the special deposits.
|
||||
9978.10 Supplier#000485455 ROMANIA 17485454 Manufacturer#2 t7F3a1y9E6EW,5w 29-315-378-1870 leep blithely among the carefully final deposits
|
||||
9977.85 Supplier#000385307 UNITED KINGDOM 18635252 Manufacturer#2 BCVDNLgOUmXo 33-105-512-8982 regular courts must have to sleep slyly packages. dependencies around the special p
|
||||
9977.78 Supplier#000558710 RUSSIA 3308706 Manufacturer#2 b85FlREzDt7qZF5jERFoUGlPtC,SFrfgwmoO16 32-190-876-7346 ly special requests about the slyly regular requests affix furiou
|
||||
9977.78 Supplier#000558710 RUSSIA 13058683 Manufacturer#2 b85FlREzDt7qZF5jERFoUGlPtC,SFrfgwmoO16 32-190-876-7346 ly special requests about the slyly regular requests affix furiou
|
||||
9977.12 Supplier#000218385 UNITED KINGDOM 2468378 Manufacturer#1 0Ec6EJcwxqRODek7g5,fMW7XZpWt7vurk 33-681-192-6225 press foxes integrate fluffily along the daringly final deposits. special packages nag blithely ag
|
||||
9977.06 Supplier#000175556 ROMANIA 16175555 Manufacturer#4 QnFrj 0kk5zQtipWFnp0bB4n6ap0TkkQ 29-765-974-1131 regular foxes use carefully slyly expr
|
||||
9976.15 Supplier#000249831 ROMANIA 3249830 Manufacturer#3 GmzVxvTlqnD1zD6HUY52PiR2IwG307 Gi 29-187-368-9234 furiously. permanently regular ideas
|
||||
9975.74 Supplier#000846320 RUSSIA 8096295 Manufacturer#4 11vbNhh3ZAFeDcae 32-487-239-6035 ions would sleep furiously pending packages. depo
|
||||
9975.69 Supplier#000378812 FRANCE 15628766 Manufacturer#1 zaWMkGkdD20CG2da5baWSSPzHE T 16-867-261-3212 ng to the furiously regular deposits. furiously slow deposits above the slyl
|
||||
9975.67 Supplier#000634390 ROMANIA 13134363 Manufacturer#1 tjnoQUeQfh 29-665-426-1647 uests. ideas hang carefull
|
||||
9975.53 Supplier#000310136 ROMANIA 10810115 Manufacturer#5 6d4cdrV8 rq 29-977-903-6199 ts. packages wake. regular, final ideas after the package
|
||||
11
regression-test/data/tpch_sf100_unique_sql_p2/sql/q03.out
Normal file
11
regression-test/data/tpch_sf100_unique_sql_p2/sql/q03.out
Normal file
@ -0,0 +1,11 @@
|
||||
-- !q03 --
|
||||
249739810 492136.8537 1995-02-28 0
|
||||
165214338 485645.5293 1995-03-09 0
|
||||
507274210 485256.2467 1995-03-10 0
|
||||
202071367 474746.4068 1995-03-12 0
|
||||
37307463 474325.1938 1995-02-06 0
|
||||
461984355 468002.5274 1995-03-13 0
|
||||
100810368 467932.7645 1995-02-28 0
|
||||
74015523 467786.8027 1995-03-14 0
|
||||
402772582 463367.0665 1995-03-10 0
|
||||
367111712 462559.3977 1995-03-01 0
|
||||
@ -0,0 +1,6 @@
|
||||
-- !q04 --
|
||||
1-URGENT 1051801
|
||||
2-HIGH 1051366
|
||||
3-MEDIUM 1051587
|
||||
4-NOT SPECIFIED 1050950
|
||||
5-LOW 1051725
|
||||
@ -0,0 +1,6 @@
|
||||
-- !q05 --
|
||||
VIETNAM 5310749966.8670
|
||||
INDIA 5296094837.7503
|
||||
JAPAN 5282184528.8254
|
||||
CHINA 5270934901.5602
|
||||
INDONESIA 5270340980.4608
|
||||
@ -0,0 +1,2 @@
|
||||
-- !q06 --
|
||||
12330426888.4637
|
||||
@ -0,0 +1,5 @@
|
||||
-- !q07 --
|
||||
FRANCE GERMANY 1995 5296106289.7407
|
||||
FRANCE GERMANY 1996 5313955237.5650
|
||||
GERMANY FRANCE 1995 5286060012.2108
|
||||
GERMANY FRANCE 1996 5324729138.8922
|
||||
@ -0,0 +1,3 @@
|
||||
-- !q08 --
|
||||
1995 0.0395
|
||||
1996 0.0390
|
||||
176
regression-test/data/tpch_sf100_unique_sql_p2/sql/q09.out
Normal file
176
regression-test/data/tpch_sf100_unique_sql_p2/sql/q09.out
Normal file
@ -0,0 +1,176 @@
|
||||
-- !q09 --
|
||||
ALGERIA 1998 2746388473.8032
|
||||
ALGERIA 1997 4705096214.1934
|
||||
ALGERIA 1996 4691101028.3880
|
||||
ALGERIA 1995 4692240612.2209
|
||||
ALGERIA 1994 4677512644.2049
|
||||
ALGERIA 1993 4684367583.8281
|
||||
ALGERIA 1992 4704266160.0314
|
||||
ARGENTINA 1998 2718513010.8517
|
||||
ARGENTINA 1997 4646318596.6846
|
||||
ARGENTINA 1996 4656102598.0412
|
||||
ARGENTINA 1995 4652753173.2283
|
||||
ARGENTINA 1994 4645991799.5327
|
||||
ARGENTINA 1993 4643401137.5627
|
||||
ARGENTINA 1992 4617848896.7718
|
||||
BRAZIL 1998 2731140677.1163
|
||||
BRAZIL 1997 4675931143.5076
|
||||
BRAZIL 1996 4665397071.9817
|
||||
BRAZIL 1995 4661653435.2637
|
||||
BRAZIL 1994 4664829056.3807
|
||||
BRAZIL 1993 4675246060.5211
|
||||
BRAZIL 1992 4699378591.6169
|
||||
CANADA 1998 2737663014.1858
|
||||
CANADA 1997 4680387035.7293
|
||||
CANADA 1996 4682077548.1279
|
||||
CANADA 1995 4683532053.5255
|
||||
CANADA 1994 4661595473.3244
|
||||
CANADA 1993 4663422610.2709
|
||||
CANADA 1992 4693236211.6702
|
||||
CHINA 1998 2734194369.8060
|
||||
CHINA 1997 4683510835.7253
|
||||
CHINA 1996 4694563430.7904
|
||||
CHINA 1995 4659549932.0340
|
||||
CHINA 1994 4668649255.3147
|
||||
CHINA 1993 4653663845.2788
|
||||
CHINA 1992 4671594192.3921
|
||||
EGYPT 1998 2730076443.1884
|
||||
EGYPT 1997 4641217395.7312
|
||||
EGYPT 1996 4682023903.3341
|
||||
EGYPT 1995 4656985688.9953
|
||||
EGYPT 1994 4639974596.4792
|
||||
EGYPT 1993 4654217487.6341
|
||||
EGYPT 1992 4655508405.6203
|
||||
ETHIOPIA 1998 2771891798.5626
|
||||
ETHIOPIA 1997 4691462902.6513
|
||||
ETHIOPIA 1996 4699807893.8519
|
||||
ETHIOPIA 1995 4712019051.0500
|
||||
ETHIOPIA 1994 4714485895.7143
|
||||
ETHIOPIA 1993 4673334464.7560
|
||||
ETHIOPIA 1992 4709982012.2332
|
||||
FRANCE 1998 2749352687.4774
|
||||
FRANCE 1997 4691958256.2337
|
||||
FRANCE 1996 4720197405.4933
|
||||
FRANCE 1995 4702056754.2862
|
||||
FRANCE 1994 4701239088.1534
|
||||
FRANCE 1993 4712310290.5728
|
||||
FRANCE 1992 4706154746.0950
|
||||
GERMANY 1998 2767125834.8583
|
||||
GERMANY 1997 4703923545.6778
|
||||
GERMANY 1996 4690487560.3747
|
||||
GERMANY 1995 4686747664.0253
|
||||
GERMANY 1994 4660352911.1835
|
||||
GERMANY 1993 4692160055.6115
|
||||
GERMANY 1992 4691498075.8817
|
||||
INDIA 1998 2732579085.7320
|
||||
INDIA 1997 4678477185.9828
|
||||
INDIA 1996 4673866490.2673
|
||||
INDIA 1995 4674959076.8220
|
||||
INDIA 1994 4681827178.3883
|
||||
INDIA 1993 4643481746.8153
|
||||
INDIA 1992 4665882504.0580
|
||||
INDONESIA 1998 2745112789.9308
|
||||
INDONESIA 1997 4665596134.6372
|
||||
INDONESIA 1996 4669667677.0694
|
||||
INDONESIA 1995 4667166725.6425
|
||||
INDONESIA 1994 4662762228.6715
|
||||
INDONESIA 1993 4656778134.1717
|
||||
INDONESIA 1992 4670973296.6516
|
||||
IRAN 1998 2723216170.3955
|
||||
IRAN 1997 4609684248.8494
|
||||
IRAN 1996 4628753160.9335
|
||||
IRAN 1995 4627120996.2797
|
||||
IRAN 1994 4608487551.0284
|
||||
IRAN 1993 4620764336.3543
|
||||
IRAN 1992 4627902203.8205
|
||||
IRAQ 1998 2740906684.5899
|
||||
IRAQ 1997 4666298134.8121
|
||||
IRAQ 1996 4684322817.7602
|
||||
IRAQ 1995 4653983196.7067
|
||||
IRAQ 1994 4683335111.0202
|
||||
IRAQ 1993 4667160512.2664
|
||||
IRAQ 1992 4678315491.6055
|
||||
JAPAN 1998 2724504496.6036
|
||||
JAPAN 1997 4609764983.8460
|
||||
JAPAN 1996 4650986737.2104
|
||||
JAPAN 1995 4663812104.3333
|
||||
JAPAN 1994 4633301980.7018
|
||||
JAPAN 1993 4638916610.4736
|
||||
JAPAN 1992 4656081490.0799
|
||||
JORDAN 1998 2742880098.5775
|
||||
JORDAN 1997 4672752862.4339
|
||||
JORDAN 1996 4667670128.2117
|
||||
JORDAN 1995 4651272615.6814
|
||||
JORDAN 1994 4670362946.3448
|
||||
JORDAN 1993 4673339129.9122
|
||||
JORDAN 1992 4675813230.0285
|
||||
KENYA 1998 2717580811.0000
|
||||
KENYA 1997 4606427219.5743
|
||||
KENYA 1996 4628365122.1309
|
||||
KENYA 1995 4611166905.2203
|
||||
KENYA 1994 4616660205.3054
|
||||
KENYA 1993 4629037306.5682
|
||||
KENYA 1992 4635940424.6568
|
||||
MOROCCO 1998 2728973692.6920
|
||||
MOROCCO 1997 4677385007.6678
|
||||
MOROCCO 1996 4691138516.3593
|
||||
MOROCCO 1995 4672866595.7418
|
||||
MOROCCO 1994 4679363707.8996
|
||||
MOROCCO 1993 4657343605.4867
|
||||
MOROCCO 1992 4673293158.1836
|
||||
MOZAMBIQUE 1998 2746870372.9866
|
||||
MOZAMBIQUE 1997 4657797818.0251
|
||||
MOZAMBIQUE 1996 4680907763.2698
|
||||
MOZAMBIQUE 1995 4679365111.6934
|
||||
MOZAMBIQUE 1994 4650089862.9296
|
||||
MOZAMBIQUE 1993 4674781658.7232
|
||||
MOZAMBIQUE 1992 4703066893.3666
|
||||
PERU 1998 2701947354.7482
|
||||
PERU 1997 4623755865.6737
|
||||
PERU 1996 4653145387.6256
|
||||
PERU 1995 4649971644.3930
|
||||
PERU 1994 4640145803.9750
|
||||
PERU 1993 4630471111.0602
|
||||
PERU 1992 4629977353.5552
|
||||
ROMANIA 1998 2730185251.6769
|
||||
ROMANIA 1997 4662919818.6774
|
||||
ROMANIA 1996 4692623447.6039
|
||||
ROMANIA 1995 4683093538.1776
|
||||
ROMANIA 1994 4656908200.8979
|
||||
ROMANIA 1993 4673109064.6419
|
||||
ROMANIA 1992 4659501236.8597
|
||||
RUSSIA 1998 2738455915.5436
|
||||
RUSSIA 1997 4701455238.0605
|
||||
RUSSIA 1996 4694648504.0344
|
||||
RUSSIA 1995 4674020866.8064
|
||||
RUSSIA 1994 4687989534.5975
|
||||
RUSSIA 1993 4680591337.8529
|
||||
RUSSIA 1992 4684865871.5704
|
||||
SAUDI ARABIA 1998 2722192493.2115
|
||||
SAUDI ARABIA 1997 4646872112.0183
|
||||
SAUDI ARABIA 1996 4679097125.4999
|
||||
SAUDI ARABIA 1995 4659365308.2421
|
||||
SAUDI ARABIA 1994 4668096847.3099
|
||||
SAUDI ARABIA 1993 4647885741.9225
|
||||
SAUDI ARABIA 1992 4665645732.0885
|
||||
UNITED KINGDOM 1998 2757252921.4935
|
||||
UNITED KINGDOM 1997 4687915843.3827
|
||||
UNITED KINGDOM 1996 4725596237.9521
|
||||
UNITED KINGDOM 1995 4692146767.0496
|
||||
UNITED KINGDOM 1994 4717398081.8118
|
||||
UNITED KINGDOM 1993 4694183885.2941
|
||||
UNITED KINGDOM 1992 4722609721.7765
|
||||
UNITED STATES 1998 2744344335.0383
|
||||
UNITED STATES 1997 4652698592.5866
|
||||
UNITED STATES 1996 4670553955.7057
|
||||
UNITED STATES 1995 4659218769.7598
|
||||
UNITED STATES 1994 4671044724.0807
|
||||
UNITED STATES 1993 4680519402.4766
|
||||
UNITED STATES 1992 4707714157.3208
|
||||
VIETNAM 1998 2741387136.2468
|
||||
VIETNAM 1997 4661928954.8541
|
||||
VIETNAM 1996 4690535970.8003
|
||||
VIETNAM 1995 4692078285.1287
|
||||
VIETNAM 1994 4705541885.2493
|
||||
VIETNAM 1993 4708733491.5609
|
||||
VIETNAM 1992 4681498238.7580
|
||||
21
regression-test/data/tpch_sf100_unique_sql_p2/sql/q10.out
Normal file
21
regression-test/data/tpch_sf100_unique_sql_p2/sql/q10.out
Normal file
@ -0,0 +1,21 @@
|
||||
-- !q10 --
|
||||
7450894 Customer#007450894 936768.8469 927.18 ARGENTINA hxPXtdJ84fyOre7gMSCv2rzBvt cw5G3S4aivxm 11-833-256-7879 packages are inside the finally bold requests. final, ironic ideas doze slyly regular deposit
|
||||
9739771 Customer#009739771 842966.5285 1286.48 JORDAN tC7c8bZ7 By6nEoHRL 23-281-450-4794 p furiously deposits? deposits affix furiously: pinto beans are blithely after the slyly final accounts. ca
|
||||
4571035 Customer#004571035 838705.6168 6704.13 UNITED KINGDOM 20IDf0Fx1ahSqImFXAEMSopHx3ic,h8Lj 33-138-285-3770 e carefully across the quickly ironic requests! fluffily close instructions cajole carefully. furious
|
||||
637855 Customer#000637855 812034.3778 2674.86 MOZAMBIQUE q5TskwlicGP 26-852-120-2850 al instructions sleep blithely. furiously final platelets nag across the ca
|
||||
10781974 Customer#010781974 801735.5176 5079.77 ROMANIA Cv2p,eRTt8C WwJV61XTYA,6T4obB 29-651-722-6239 egular notornis. requests wake alongsid
|
||||
11361613 Customer#011361613 800558.4337 4644.71 INDONESIA jWKghIqWp5Vzt2s 19-344-539-9187 latelets cajole slyly along the unusual accounts. dependencies use furiously ironic requests. enticingly iro
|
||||
1259743 Customer#001259743 793274.7846 2592.74 ETHIOPIA YVe ,jDra4xnKtfzS62bnoxpmGF2d8Kfi 15-733-636-6732 eposits sleep according to the even pinto beans. carefully un
|
||||
5154136 Customer#005154136 787191.1959 1028.97 MOROCCO Y,cjCdRGVz1j g8YQUGRMf5z3R 25-841-379-9394 boost quickly slyly even deposits: slyly ironic theodolite
|
||||
14986552 Customer#014986552 781645.8638 2678.94 ARGENTINA tl5yB8W1C0 11-671-762-3613 ual ideas sleep daringly after the carefully final pinto beans. furiously final accounts at th
|
||||
2905816 Customer#002905816 778729.4414 5085.53 UNITED STATES bcLOp3b9PA 34-217-584-5820 the furiously express foxes wake final, pending pinto beans. slyly silent ideas nag slyly. foxes sleep slyly accord
|
||||
6184141 Customer#006184141 772721.0973 5901.88 BRAZIL YouilzzEFBn8Q6atx F76 12-563-743-4211 en instructions between the furiously ironic pinto beans wake blithely bold deposits. fluffy p
|
||||
7852024 Customer#007852024 769688.6616 1197.57 INDIA 2 lZJ,yBgPkRHVO6yDnXeehlynZEt,W8SU4J46,R 18-141-580-3886 osits haggle quickly. ironic dependencies against the daringly express requests wak
|
||||
7183231 Customer#007183231 768455.8796 -683.01 INDIA ozSXeIbCwiOQJhN 18-270-127-8463 braids. furiously ironic instructions nag blithely around the carefully regular asymptotes. regular packages after t
|
||||
1627651 Customer#001627651 768300.3006 3059.82 MOROCCO cp3JS2a9Yu8cBKaDrTlpMirm1l1rpDo 25-732-202-4862 ts cajole carefully along the carefully final requests. special packages affix. blithely final accounts agai
|
||||
13624771 Customer#013624771 767856.1562 -168.68 IRAN sxMG5r82qFaZLAqmChvOLDNaqm 20-919-886-5399 the, final requests mold slyly according to the slyly final
|
||||
13896424 Customer#013896424 760957.6214 3798.91 INDONESIA csALLLLaTB 19-494-837-4503 cajole carefully above the carefully regular deposits. slyly fluffy accounts boost blithely reg
|
||||
4926817 Customer#004926817 758756.8533 5462.22 RUSSIA X9PvpAssUMkoi 32-610-751-1595 carefully unusual deposits haggle doggedly along
|
||||
319150 Customer#000319150 757235.8949 3257.68 IRAN l1KV7LZ3ih7cgjuQUo0iXJTb wlIvIzwD 20-837-276-7259 ly ironic requests. ironic deposits beyond the fu
|
||||
5894188 Customer#005894188 756482.0641 3062.00 BRAZIL 1PrX23NPGc 81N8nMG771nGSNGHDrWR6GsmnReX 12-372-345-6045 unts after the slyly sly dependencies
|
||||
3387028 Customer#003387028 755937.5757 3726.64 ETHIOPIA j4HWo86pMyWym 15-880-219-8399 ckly among the furiously unusual deposits. furious
|
||||
@ -0,0 +1 @@
|
||||
-- !q11 --
|
||||
@ -0,0 +1,3 @@
|
||||
-- !q12 --
|
||||
MAIL 623115 934713
|
||||
SHIP 622979 934534
|
||||
46
regression-test/data/tpch_sf100_unique_sql_p2/sql/q13.out
Normal file
46
regression-test/data/tpch_sf100_unique_sql_p2/sql/q13.out
Normal file
@ -0,0 +1,46 @@
|
||||
-- !q13 --
|
||||
0 5000183
|
||||
10 677063
|
||||
9 663581
|
||||
11 633489
|
||||
8 590905
|
||||
12 563161
|
||||
13 494077
|
||||
19 477022
|
||||
18 468778
|
||||
20 465511
|
||||
7 464075
|
||||
17 450593
|
||||
14 444860
|
||||
21 434755
|
||||
16 430766
|
||||
15 424596
|
||||
22 388464
|
||||
23 331043
|
||||
6 318884
|
||||
24 269722
|
||||
25 210010
|
||||
5 186174
|
||||
26 156661
|
||||
27 111895
|
||||
4 89788
|
||||
28 77483
|
||||
29 51144
|
||||
3 34729
|
||||
30 32656
|
||||
31 19929
|
||||
32 11840
|
||||
2 10007
|
||||
33 6599
|
||||
34 3632
|
||||
35 1963
|
||||
1 1875
|
||||
36 1062
|
||||
37 538
|
||||
38 254
|
||||
39 122
|
||||
40 64
|
||||
41 25
|
||||
42 14
|
||||
43 7
|
||||
44 1
|
||||
@ -0,0 +1,2 @@
|
||||
-- !q14 --
|
||||
16.640357
|
||||
@ -0,0 +1,2 @@
|
||||
-- !q15 --
|
||||
8831 Supplier#000008831 jvIXgLiNdSXAni5POCMq1dk 17-307-245-8592 2385908.0563
|
||||
27841
regression-test/data/tpch_sf100_unique_sql_p2/sql/q16.out
Normal file
27841
regression-test/data/tpch_sf100_unique_sql_p2/sql/q16.out
Normal file
File diff suppressed because it is too large
Load Diff
@ -0,0 +1,2 @@
|
||||
-- !q17 --
|
||||
32087019.00
|
||||
101
regression-test/data/tpch_sf100_unique_sql_p2/sql/q18.out
Normal file
101
regression-test/data/tpch_sf100_unique_sql_p2/sql/q18.out
Normal file
@ -0,0 +1,101 @@
|
||||
-- !q18 --
|
||||
Customer#011472112 11472112 458304292 1998-02-05 591036.15 322.00
|
||||
Customer#012090925 12090925 501322081 1995-02-04 586945.44 319.00
|
||||
Customer#001392379 1392379 332381222 1998-01-24 575600.00 311.00
|
||||
Customer#013458721 13458721 333307747 1997-12-19 572334.88 319.00
|
||||
Customer#008643083 8643083 84927619 1997-06-29 571417.48 316.00
|
||||
Customer#010543705 10543705 163142919 1996-06-10 569798.10 313.00
|
||||
Customer#000026377 26377 586594688 1992-04-14 569044.84 311.00
|
||||
Customer#005914657 5914657 55799200 1996-02-11 568754.48 327.00
|
||||
Customer#011461310 11461310 20662370 1992-07-22 566353.20 315.00
|
||||
Customer#007682894 7682894 532736640 1993-07-22 563532.16 316.00
|
||||
Customer#012070685 12070685 34201984 1997-06-18 563492.49 322.00
|
||||
Customer#012878113 12878113 42290181 1997-11-26 563479.57 318.00
|
||||
Customer#000506836 506836 116567399 1992-03-21 563342.71 319.00
|
||||
Customer#012848143 12848143 501771233 1994-12-06 562642.03 317.00
|
||||
Customer#003493022 3493022 182898470 1996-01-09 561296.06 318.00
|
||||
Customer#013083751 13083751 28077922 1996-10-27 560893.88 319.00
|
||||
Customer#006580315 6580315 343593507 1994-05-20 560058.60 321.00
|
||||
Customer#009427249 9427249 48881602 1993-09-19 559502.82 327.00
|
||||
Customer#009995401 9995401 530897159 1994-05-02 558771.77 305.00
|
||||
Customer#006094567 6094567 156159680 1994-11-15 558037.12 308.00
|
||||
Customer#006594658 6594658 555833473 1997-08-01 557961.99 324.00
|
||||
Customer#005925541 5925541 446215044 1992-05-13 556993.03 318.00
|
||||
Customer#007010650 7010650 587222276 1993-12-17 555946.71 329.00
|
||||
Customer#008211575 8211575 218305350 1992-12-19 555691.15 316.00
|
||||
Customer#005523215 5523215 499594150 1997-12-30 552295.59 322.00
|
||||
Customer#003592226 3592226 94936672 1992-02-28 551850.29 307.00
|
||||
Customer#006048598 6048598 45897379 1994-05-30 550195.48 318.00
|
||||
Customer#013889867 13889867 322196069 1992-12-24 549996.06 313.00
|
||||
Customer#007847146 7847146 75799361 1994-06-22 549769.03 307.00
|
||||
Customer#002538608 2538608 406952547 1992-04-14 549380.73 304.00
|
||||
Customer#011113726 11113726 346088583 1996-02-21 548790.02 303.00
|
||||
Customer#003262783 3262783 327814241 1997-04-16 548355.89 319.00
|
||||
Customer#002099413 2099413 507968289 1993-01-23 547809.74 316.00
|
||||
Customer#009950764 9950764 442334435 1996-10-07 547526.61 308.00
|
||||
Customer#012123581 12123581 496277122 1995-03-13 547335.02 312.00
|
||||
Customer#005800261 5800261 493616454 1997-01-11 547151.89 314.00
|
||||
Customer#002395564 2395564 584277191 1993-10-14 546290.18 311.00
|
||||
Customer#001382375 1382375 43491654 1992-05-20 546035.62 308.00
|
||||
Customer#001359841 1359841 373555077 1995-05-08 545367.48 304.00
|
||||
Customer#000569440 569440 119020930 1995-02-19 545201.16 309.00
|
||||
Customer#012179552 12179552 157723879 1992-01-06 545008.93 320.00
|
||||
Customer#000328568 328568 584293472 1997-02-04 544997.41 317.00
|
||||
Customer#005098117 5098117 82043264 1996-04-15 544838.33 330.00
|
||||
Customer#012375202 12375202 272622276 1995-08-13 543957.13 301.00
|
||||
Customer#006394964 6394964 410876964 1994-11-15 543654.37 324.00
|
||||
Customer#012130760 12130760 152975303 1992-11-23 543496.47 311.00
|
||||
Customer#005021956 5021956 163897538 1992-05-10 543411.84 315.00
|
||||
Customer#014745380 14745380 323533249 1993-03-31 543411.82 322.00
|
||||
Customer#005387083 5387083 394137797 1993-09-14 542890.62 308.00
|
||||
Customer#001070318 1070318 91475014 1996-11-15 542874.97 314.00
|
||||
Customer#011639476 11639476 512860422 1995-11-20 542855.00 311.00
|
||||
Customer#009557132 9557132 80293413 1992-06-12 542680.80 305.00
|
||||
Customer#012639745 12639745 215706726 1992-10-29 541693.09 305.00
|
||||
Customer#010933264 10933264 505312545 1995-07-19 541378.70 309.00
|
||||
Customer#006633514 6633514 561405959 1994-09-10 541176.68 308.00
|
||||
Customer#008668609 8668609 19730208 1994-01-24 540531.95 305.00
|
||||
Customer#000793051 793051 103963585 1996-10-27 540445.27 313.00
|
||||
Customer#000194932 194932 233298977 1997-11-16 540319.71 304.00
|
||||
Customer#007585013 7585013 41325120 1997-05-02 540248.88 309.00
|
||||
Customer#005034994 5034994 571000834 1997-08-02 540244.15 303.00
|
||||
Customer#013646452 13646452 109414535 1997-01-09 539803.25 302.00
|
||||
Customer#010763563 10763563 575451169 1994-01-18 539403.56 329.00
|
||||
Customer#003878665 3878665 465165376 1995-08-03 539331.83 312.00
|
||||
Customer#009475150 9475150 486502979 1995-01-21 539173.83 308.00
|
||||
Customer#007359265 7359265 402919200 1997-03-14 539028.84 312.00
|
||||
Customer#009274702 9274702 545970215 1997-12-17 538976.86 303.00
|
||||
Customer#008402254 8402254 539392967 1993-02-23 538886.31 333.00
|
||||
Customer#008654869 8654869 100176839 1993-04-12 538846.61 317.00
|
||||
Customer#007498450 7498450 140933856 1993-04-16 538585.17 309.00
|
||||
Customer#001291604 1291604 220248583 1995-08-18 538171.18 304.00
|
||||
Customer#005159660 5159660 160674945 1996-05-16 537771.10 310.00
|
||||
Customer#014286853 14286853 423877508 1995-03-02 536949.18 319.00
|
||||
Customer#008779822 8779822 211965092 1996-07-18 536768.43 314.00
|
||||
Customer#004955200 4955200 510010278 1996-01-08 536693.57 302.00
|
||||
Customer#008208034 8208034 446989058 1993-07-12 536601.61 315.00
|
||||
Customer#009666952 9666952 475794275 1994-09-23 536427.97 322.00
|
||||
Customer#011930665 11930665 107950688 1995-08-05 536328.78 309.00
|
||||
Customer#014831182 14831182 92086567 1996-06-12 536294.92 322.00
|
||||
Customer#009515017 9515017 462317029 1997-01-28 535876.92 308.00
|
||||
Customer#008795228 8795228 275406304 1994-12-19 535829.88 304.00
|
||||
Customer#013677323 13677323 387783079 1992-04-22 535504.63 316.00
|
||||
Customer#004965692 4965692 250733185 1994-06-12 535482.20 306.00
|
||||
Customer#004663856 4663856 159914310 1996-09-12 535322.28 315.00
|
||||
Customer#014560954 14560954 420830819 1994-03-05 534940.24 301.00
|
||||
Customer#003555572 3555572 190167361 1994-08-29 534477.19 304.00
|
||||
Customer#000299162 299162 303098309 1996-01-28 534421.58 315.00
|
||||
Customer#005747806 5747806 540886884 1994-04-14 534288.51 314.00
|
||||
Customer#013094119 13094119 111128577 1995-05-09 534239.89 316.00
|
||||
Customer#008259454 8259454 546232737 1997-12-07 534055.44 303.00
|
||||
Customer#000090529 90529 112311041 1998-01-22 534035.86 307.00
|
||||
Customer#004938865 4938865 595346338 1996-08-18 533883.75 310.00
|
||||
Customer#012726752 12726752 92511430 1995-03-06 533441.05 318.00
|
||||
Customer#009638569 9638569 16783360 1998-02-16 533372.62 308.00
|
||||
Customer#000437614 437614 569537412 1992-01-07 533305.85 305.00
|
||||
Customer#011219830 11219830 156065860 1996-07-03 533119.17 325.00
|
||||
Customer#005060768 5060768 255829888 1997-03-18 533054.97 308.00
|
||||
Customer#014112568 14112568 280056096 1997-01-30 532881.87 313.00
|
||||
Customer#012373496 12373496 61135843 1993-01-30 532734.68 303.00
|
||||
Customer#007910675 7910675 158520577 1992-02-29 532689.01 304.00
|
||||
Customer#013106491 13106491 88925410 1995-01-10 532631.76 310.00
|
||||
@ -0,0 +1,2 @@
|
||||
-- !q19 --
|
||||
298937728.8820
|
||||
17972
regression-test/data/tpch_sf100_unique_sql_p2/sql/q20.out
Normal file
17972
regression-test/data/tpch_sf100_unique_sql_p2/sql/q20.out
Normal file
File diff suppressed because it is too large
Load Diff
101
regression-test/data/tpch_sf100_unique_sql_p2/sql/q21.out
Normal file
101
regression-test/data/tpch_sf100_unique_sql_p2/sql/q21.out
Normal file
@ -0,0 +1,101 @@
|
||||
-- !q21 --
|
||||
Supplier#000747754 26
|
||||
Supplier#000458746 25
|
||||
Supplier#000571158 25
|
||||
Supplier#000107007 24
|
||||
Supplier#000410726 24
|
||||
Supplier#000084585 23
|
||||
Supplier#000112694 23
|
||||
Supplier#000142113 23
|
||||
Supplier#000152064 23
|
||||
Supplier#000209763 23
|
||||
Supplier#000388227 23
|
||||
Supplier#000407925 23
|
||||
Supplier#000560459 23
|
||||
Supplier#000694752 23
|
||||
Supplier#000703020 23
|
||||
Supplier#000729149 23
|
||||
Supplier#000891339 23
|
||||
Supplier#000975089 23
|
||||
Supplier#000000380 22
|
||||
Supplier#000035755 22
|
||||
Supplier#000164253 22
|
||||
Supplier#000297749 22
|
||||
Supplier#000345040 22
|
||||
Supplier#000377932 22
|
||||
Supplier#000408542 22
|
||||
Supplier#000418032 22
|
||||
Supplier#000442372 22
|
||||
Supplier#000511122 22
|
||||
Supplier#000625330 22
|
||||
Supplier#000632192 22
|
||||
Supplier#000818929 22
|
||||
Supplier#000854905 22
|
||||
Supplier#000904387 22
|
||||
Supplier#000026807 21
|
||||
Supplier#000040020 21
|
||||
Supplier#000045516 21
|
||||
Supplier#000107055 21
|
||||
Supplier#000114816 21
|
||||
Supplier#000115320 21
|
||||
Supplier#000138108 21
|
||||
Supplier#000217006 21
|
||||
Supplier#000218071 21
|
||||
Supplier#000218308 21
|
||||
Supplier#000230746 21
|
||||
Supplier#000248169 21
|
||||
Supplier#000296769 21
|
||||
Supplier#000321127 21
|
||||
Supplier#000381528 21
|
||||
Supplier#000429550 21
|
||||
Supplier#000464989 21
|
||||
Supplier#000523861 21
|
||||
Supplier#000735189 21
|
||||
Supplier#000749856 21
|
||||
Supplier#000797502 21
|
||||
Supplier#000846710 21
|
||||
Supplier#000852316 21
|
||||
Supplier#000876643 21
|
||||
Supplier#000940195 21
|
||||
Supplier#000977626 21
|
||||
Supplier#000004009 20
|
||||
Supplier#000075957 20
|
||||
Supplier#000100362 20
|
||||
Supplier#000114819 20
|
||||
Supplier#000149956 20
|
||||
Supplier#000162442 20
|
||||
Supplier#000168720 20
|
||||
Supplier#000187595 20
|
||||
Supplier#000194735 20
|
||||
Supplier#000218315 20
|
||||
Supplier#000218879 20
|
||||
Supplier#000227225 20
|
||||
Supplier#000231968 20
|
||||
Supplier#000250950 20
|
||||
Supplier#000258760 20
|
||||
Supplier#000274376 20
|
||||
Supplier#000286235 20
|
||||
Supplier#000318315 20
|
||||
Supplier#000323593 20
|
||||
Supplier#000326453 20
|
||||
Supplier#000343051 20
|
||||
Supplier#000349163 20
|
||||
Supplier#000372217 20
|
||||
Supplier#000379187 20
|
||||
Supplier#000392259 20
|
||||
Supplier#000398512 20
|
||||
Supplier#000414004 20
|
||||
Supplier#000423101 20
|
||||
Supplier#000435864 20
|
||||
Supplier#000444400 20
|
||||
Supplier#000444741 20
|
||||
Supplier#000478679 20
|
||||
Supplier#000484714 20
|
||||
Supplier#000516332 20
|
||||
Supplier#000520712 20
|
||||
Supplier#000523584 20
|
||||
Supplier#000523677 20
|
||||
Supplier#000547932 20
|
||||
Supplier#000559301 20
|
||||
Supplier#000559552 20
|
||||
Supplier#000599009 20
|
||||
@ -0,0 +1,8 @@
|
||||
-- !q22 --
|
||||
13 90748 679530260.80
|
||||
17 91314 685030261.91
|
||||
18 91293 684593250.42
|
||||
23 90359 677680422.77
|
||||
29 91123 683678024.88
|
||||
30 91358 685118386.83
|
||||
31 90553 678671645.35
|
||||
17
regression-test/suites/tpch_sf100_unique_p2/ddl/customer.sql
Normal file
17
regression-test/suites/tpch_sf100_unique_p2/ddl/customer.sql
Normal file
@ -0,0 +1,17 @@
|
||||
CREATE TABLE IF NOT EXISTS customer (
|
||||
c_custkey int NOT NULL,
|
||||
c_name VARCHAR(25) NOT NULL,
|
||||
c_address VARCHAR(40) NOT NULL,
|
||||
c_nationkey int NOT NULL,
|
||||
c_phone VARCHAR(15) NOT NULL,
|
||||
c_acctbal decimal(15, 2) NOT NULL,
|
||||
c_mktsegment VARCHAR(10) NOT NULL,
|
||||
c_comment VARCHAR(117) NOT NULL
|
||||
)ENGINE=OLAP
|
||||
UNIQUE KEY(`c_custkey`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`c_custkey`) BUCKETS 24
|
||||
PROPERTIES (
|
||||
"replication_num" = "3"
|
||||
)
|
||||
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM customer where C_CUSTKEY >= 0;
|
||||
@ -0,0 +1,6 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/customer.tbl")
|
||||
INTO TABLE customer
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(c_custkey, c_name, c_address, c_nationkey, c_phone, c_acctbal, c_mktsegment, c_comment, temp)
|
||||
)
|
||||
@ -0,0 +1,7 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/customer.tbl")
|
||||
INTO TABLE customer
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(c_custkey, c_name, c_address, c_nationkey, c_phone, c_acctbal, c_mktsegment, c_comment, temp)
|
||||
ORDER BY c_custkey
|
||||
)
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM customer where C_CUSTKEY > 7500000;
|
||||
@ -0,0 +1,18 @@
|
||||
CREATE TABLE IF NOT EXISTS customer (
|
||||
c_custkey int NOT NULL,
|
||||
c_name VARCHAR(25) NOT NULL,
|
||||
c_address VARCHAR(40) NOT NULL,
|
||||
c_nationkey int NOT NULL,
|
||||
c_phone VARCHAR(15) NOT NULL,
|
||||
c_acctbal decimal(15, 2) NOT NULL,
|
||||
c_mktsegment VARCHAR(10) NOT NULL,
|
||||
c_comment VARCHAR(117) NOT NULL
|
||||
)ENGINE=OLAP
|
||||
UNIQUE KEY(`c_custkey`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`c_custkey`) BUCKETS 24
|
||||
PROPERTIES (
|
||||
"function_column.sequence_type" = 'int',
|
||||
"replication_num" = "3"
|
||||
)
|
||||
|
||||
25
regression-test/suites/tpch_sf100_unique_p2/ddl/lineitem.sql
Normal file
25
regression-test/suites/tpch_sf100_unique_p2/ddl/lineitem.sql
Normal file
@ -0,0 +1,25 @@
|
||||
CREATE TABLE IF NOT EXISTS lineitem (
|
||||
l_shipdate DATE NOT NULL,
|
||||
l_orderkey bigint NOT NULL,
|
||||
l_linenumber int not null,
|
||||
l_partkey int NOT NULL,
|
||||
l_suppkey int not null,
|
||||
l_quantity decimal(15, 2) NOT NULL,
|
||||
l_extendedprice decimal(15, 2) NOT NULL,
|
||||
l_discount decimal(15, 2) NOT NULL,
|
||||
l_tax decimal(15, 2) NOT NULL,
|
||||
l_returnflag VARCHAR(1) NOT NULL,
|
||||
l_linestatus VARCHAR(1) NOT NULL,
|
||||
l_commitdate DATE NOT NULL,
|
||||
l_receiptdate DATE NOT NULL,
|
||||
l_shipinstruct VARCHAR(25) NOT NULL,
|
||||
l_shipmode VARCHAR(10) NOT NULL,
|
||||
l_comment VARCHAR(44) NOT NULL
|
||||
)ENGINE=OLAP
|
||||
UNIQUE KEY(`l_shipdate`, `l_orderkey`,`l_linenumber`,`l_partkey`,`l_suppkey`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`l_orderkey`) BUCKETS 96
|
||||
PROPERTIES (
|
||||
"replication_num" = "3"
|
||||
)
|
||||
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM lineitem where l_linenumber >= 0;
|
||||
@ -0,0 +1,6 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/lineitem.tbl.*")
|
||||
INTO TABLE lineitem
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(l_orderkey, l_partkey, l_suppkey, l_linenumber, l_quantity, l_extendedprice, l_discount, l_tax, l_returnflag,l_linestatus, l_shipdate,l_commitdate,l_receiptdate,l_shipinstruct,l_shipmode,l_comment,temp)
|
||||
)
|
||||
@ -0,0 +1,7 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/lineitem.tbl.*")
|
||||
INTO TABLE lineitem
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(l_orderkey, l_partkey, l_suppkey, l_linenumber, l_quantity, l_extendedprice, l_discount, l_tax, l_returnflag,l_linestatus, l_shipdate,l_commitdate,l_receiptdate,l_shipinstruct,l_shipmode,l_comment,temp)
|
||||
ORDER BY l_orderkey
|
||||
)
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM lineitem where l_orderkey >= 240000001 and l_orderkey <= 360000000;
|
||||
@ -0,0 +1,26 @@
|
||||
CREATE TABLE IF NOT EXISTS lineitem (
|
||||
l_shipdate DATE NOT NULL,
|
||||
l_orderkey bigint NOT NULL,
|
||||
l_linenumber int not null,
|
||||
l_partkey int NOT NULL,
|
||||
l_suppkey int not null,
|
||||
l_quantity decimal(15, 2) NOT NULL,
|
||||
l_extendedprice decimal(15, 2) NOT NULL,
|
||||
l_discount decimal(15, 2) NOT NULL,
|
||||
l_tax decimal(15, 2) NOT NULL,
|
||||
l_returnflag VARCHAR(1) NOT NULL,
|
||||
l_linestatus VARCHAR(1) NOT NULL,
|
||||
l_commitdate DATE NOT NULL,
|
||||
l_receiptdate DATE NOT NULL,
|
||||
l_shipinstruct VARCHAR(25) NOT NULL,
|
||||
l_shipmode VARCHAR(10) NOT NULL,
|
||||
l_comment VARCHAR(44) NOT NULL
|
||||
)ENGINE=OLAP
|
||||
UNIQUE KEY(`l_shipdate`, `l_orderkey`,`l_linenumber`,`l_partkey`,`l_suppkey`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`l_orderkey`) BUCKETS 96
|
||||
PROPERTIES (
|
||||
"function_column.sequence_type" = 'DATE',
|
||||
"replication_num" = "3"
|
||||
)
|
||||
|
||||
13
regression-test/suites/tpch_sf100_unique_p2/ddl/nation.sql
Normal file
13
regression-test/suites/tpch_sf100_unique_p2/ddl/nation.sql
Normal file
@ -0,0 +1,13 @@
|
||||
CREATE TABLE IF NOT EXISTS nation (
|
||||
`n_nationkey` int(11) NOT NULL,
|
||||
`n_name` varchar(25) NOT NULL,
|
||||
`n_regionkey` int(11) NOT NULL,
|
||||
`n_comment` varchar(152) NULL
|
||||
) ENGINE=OLAP
|
||||
UNIQUE KEY(`N_NATIONKEY`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`N_NATIONKEY`) BUCKETS 1
|
||||
PROPERTIES (
|
||||
"replication_num" = "3"
|
||||
);
|
||||
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM nation where n_nationkey >= 0;
|
||||
@ -0,0 +1,6 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/nation.tbl")
|
||||
INTO TABLE nation
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(n_nationkey, n_name, n_regionkey, n_comment, temp)
|
||||
)
|
||||
@ -0,0 +1,7 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/nation.tbl")
|
||||
INTO TABLE nation
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(n_nationkey, n_name, n_regionkey, n_comment, temp)
|
||||
ORDER BY n_nationkey
|
||||
)
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM nation where n_nationkey < 10;
|
||||
@ -0,0 +1,14 @@
|
||||
CREATE TABLE IF NOT EXISTS nation (
|
||||
`n_nationkey` int(11) NOT NULL,
|
||||
`n_name` varchar(25) NOT NULL,
|
||||
`n_regionkey` int(11) NOT NULL,
|
||||
`n_comment` varchar(152) NULL
|
||||
) ENGINE=OLAP
|
||||
UNIQUE KEY(`N_NATIONKEY`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`N_NATIONKEY`) BUCKETS 1
|
||||
PROPERTIES (
|
||||
"function_column.sequence_type" = 'int',
|
||||
"replication_num" = "3"
|
||||
);
|
||||
|
||||
17
regression-test/suites/tpch_sf100_unique_p2/ddl/orders.sql
Normal file
17
regression-test/suites/tpch_sf100_unique_p2/ddl/orders.sql
Normal file
@ -0,0 +1,17 @@
|
||||
CREATE TABLE IF NOT EXISTS orders (
|
||||
o_orderkey bigint NOT NULL,
|
||||
o_orderdate DATE NOT NULL,
|
||||
o_custkey int NOT NULL,
|
||||
o_orderstatus VARCHAR(1) NOT NULL,
|
||||
o_totalprice decimal(15, 2) NOT NULL,
|
||||
o_orderpriority VARCHAR(15) NOT NULL,
|
||||
o_clerk VARCHAR(15) NOT NULL,
|
||||
o_shippriority int NOT NULL,
|
||||
o_comment VARCHAR(79) NOT NULL
|
||||
)ENGINE=OLAP
|
||||
UNIQUE KEY(`o_orderkey`, `o_orderdate`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`o_orderkey`) BUCKETS 96
|
||||
PROPERTIES (
|
||||
"replication_num" = "3"
|
||||
)
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM orders where o_orderkey >= 0;
|
||||
@ -0,0 +1,6 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/orders.tbl.*")
|
||||
INTO TABLE orders
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(o_orderkey, o_custkey, o_orderstatus, o_totalprice, o_orderdate, o_orderpriority, o_clerk, o_shippriority, o_comment, temp)
|
||||
)
|
||||
@ -0,0 +1,7 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/orders.tbl.*")
|
||||
INTO TABLE orders
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(o_orderkey, o_custkey, o_orderstatus, o_totalprice, o_orderdate, o_orderpriority, o_clerk, o_shippriority, o_comment, temp)
|
||||
ORDER BY o_orderkey
|
||||
)
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM orders where o_orderkey >= 240000001 and o_orderkey <= 360000000;
|
||||
@ -0,0 +1,18 @@
|
||||
CREATE TABLE IF NOT EXISTS orders (
|
||||
o_orderkey bigint NOT NULL,
|
||||
o_orderdate DATE NOT NULL,
|
||||
o_custkey int NOT NULL,
|
||||
o_orderstatus VARCHAR(1) NOT NULL,
|
||||
o_totalprice decimal(15, 2) NOT NULL,
|
||||
o_orderpriority VARCHAR(15) NOT NULL,
|
||||
o_clerk VARCHAR(15) NOT NULL,
|
||||
o_shippriority int NOT NULL,
|
||||
o_comment VARCHAR(79) NOT NULL
|
||||
)ENGINE=OLAP
|
||||
UNIQUE KEY(`o_orderkey`, `o_orderdate`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`o_orderkey`) BUCKETS 96
|
||||
PROPERTIES (
|
||||
"function_column.sequence_type" = 'bigint',
|
||||
"replication_num" = "3"
|
||||
)
|
||||
18
regression-test/suites/tpch_sf100_unique_p2/ddl/part.sql
Normal file
18
regression-test/suites/tpch_sf100_unique_p2/ddl/part.sql
Normal file
@ -0,0 +1,18 @@
|
||||
CREATE TABLE IF NOT EXISTS part (
|
||||
p_partkey int NOT NULL,
|
||||
p_name VARCHAR(55) NOT NULL,
|
||||
p_mfgr VARCHAR(25) NOT NULL,
|
||||
p_brand VARCHAR(10) NOT NULL,
|
||||
p_type VARCHAR(25) NOT NULL,
|
||||
p_size int NOT NULL,
|
||||
p_container VARCHAR(10) NOT NULL,
|
||||
p_retailprice decimal(15, 2) NOT NULL,
|
||||
p_comment VARCHAR(23) NOT NULL
|
||||
)ENGINE=OLAP
|
||||
UNIQUE KEY(`p_partkey`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`p_partkey`) BUCKETS 24
|
||||
PROPERTIES (
|
||||
"replication_num" = "3"
|
||||
)
|
||||
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM part where p_partkey >= 0;
|
||||
@ -0,0 +1,6 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/part.tbl")
|
||||
INTO TABLE part
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(p_partkey, p_name, p_mfgr, p_brand, p_type, p_size, p_container, p_retailprice, p_comment, temp)
|
||||
)
|
||||
@ -0,0 +1,7 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/part.tbl")
|
||||
INTO TABLE part
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(p_partkey, p_name, p_mfgr, p_brand, p_type, p_size, p_container, p_retailprice, p_comment, temp)
|
||||
ORDER BY p_partkey
|
||||
)
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM part where p_partkey > 10000000;
|
||||
@ -0,0 +1,19 @@
|
||||
CREATE TABLE IF NOT EXISTS part (
|
||||
p_partkey int NOT NULL,
|
||||
p_name VARCHAR(55) NOT NULL,
|
||||
p_mfgr VARCHAR(25) NOT NULL,
|
||||
p_brand VARCHAR(10) NOT NULL,
|
||||
p_type VARCHAR(25) NOT NULL,
|
||||
p_size int NOT NULL,
|
||||
p_container VARCHAR(10) NOT NULL,
|
||||
p_retailprice decimal(15, 2) NOT NULL,
|
||||
p_comment VARCHAR(23) NOT NULL
|
||||
)ENGINE=OLAP
|
||||
UNIQUE KEY(`p_partkey`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`p_partkey`) BUCKETS 24
|
||||
PROPERTIES (
|
||||
"function_column.sequence_type" = 'int',
|
||||
"replication_num" = "3"
|
||||
)
|
||||
|
||||
14
regression-test/suites/tpch_sf100_unique_p2/ddl/partsupp.sql
Normal file
14
regression-test/suites/tpch_sf100_unique_p2/ddl/partsupp.sql
Normal file
@ -0,0 +1,14 @@
|
||||
CREATE TABLE IF NOT EXISTS partsupp (
|
||||
ps_partkey int NOT NULL,
|
||||
ps_suppkey int NOT NULL,
|
||||
ps_availqty int NOT NULL,
|
||||
ps_supplycost decimal(15, 2) NOT NULL,
|
||||
ps_comment VARCHAR(199) NOT NULL
|
||||
)ENGINE=OLAP
|
||||
UNIQUE KEY(`ps_partkey`,`ps_suppkey`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`ps_partkey`) BUCKETS 24
|
||||
PROPERTIES (
|
||||
"replication_num" = "3"
|
||||
)
|
||||
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM partsupp where ps_partkey >= 0;
|
||||
@ -0,0 +1,6 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/partsupp.tbl.*")
|
||||
INTO TABLE partsupp
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(ps_partkey, ps_suppkey, ps_availqty, ps_supplycost, ps_comment, temp)
|
||||
)
|
||||
@ -0,0 +1,7 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/partsupp.tbl.*")
|
||||
INTO TABLE partsupp
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(ps_partkey, ps_suppkey, ps_availqty, ps_supplycost, ps_comment, temp)
|
||||
ORDER BY ps_partkey
|
||||
)
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM partsupp where ps_partkey >= 8000001 and ps_partkey <= 12000000;
|
||||
@ -0,0 +1,15 @@
|
||||
CREATE TABLE IF NOT EXISTS partsupp (
|
||||
ps_partkey int NOT NULL,
|
||||
ps_suppkey int NOT NULL,
|
||||
ps_availqty int NOT NULL,
|
||||
ps_supplycost decimal(15, 2) NOT NULL,
|
||||
ps_comment VARCHAR(199) NOT NULL
|
||||
)ENGINE=OLAP
|
||||
UNIQUE KEY(`ps_partkey`,`ps_suppkey`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`ps_partkey`) BUCKETS 24
|
||||
PROPERTIES (
|
||||
"function_column.sequence_type" = 'int',
|
||||
"replication_num" = "3"
|
||||
)
|
||||
|
||||
12
regression-test/suites/tpch_sf100_unique_p2/ddl/region.sql
Normal file
12
regression-test/suites/tpch_sf100_unique_p2/ddl/region.sql
Normal file
@ -0,0 +1,12 @@
|
||||
CREATE TABLE IF NOT EXISTS region (
|
||||
r_regionkey int NOT NULL,
|
||||
r_name VARCHAR(25) NOT NULL,
|
||||
r_comment VARCHAR(152)
|
||||
)ENGINE=OLAP
|
||||
UNIQUE KEY(`r_regionkey`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`r_regionkey`) BUCKETS 1
|
||||
PROPERTIES (
|
||||
"replication_num" = "3"
|
||||
)
|
||||
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM region where r_regionkey >= 0;
|
||||
@ -0,0 +1,6 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/region.tbl")
|
||||
INTO TABLE region
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(r_regionkey, r_name, r_comment, temp)
|
||||
)
|
||||
@ -0,0 +1,7 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/region.tbl")
|
||||
INTO TABLE region
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(r_regionkey, r_name, r_comment, temp)
|
||||
ORDER BY r_regionkey
|
||||
)
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM region where r_regionkey >= 3;
|
||||
@ -0,0 +1,13 @@
|
||||
CREATE TABLE IF NOT EXISTS region (
|
||||
r_regionkey int NOT NULL,
|
||||
r_name VARCHAR(25) NOT NULL,
|
||||
r_comment VARCHAR(152)
|
||||
)ENGINE=OLAP
|
||||
UNIQUE KEY(`r_regionkey`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`r_regionkey`) BUCKETS 1
|
||||
PROPERTIES (
|
||||
"function_column.sequence_type" = 'int',
|
||||
"replication_num" = "3"
|
||||
)
|
||||
|
||||
15
regression-test/suites/tpch_sf100_unique_p2/ddl/supplier.sql
Normal file
15
regression-test/suites/tpch_sf100_unique_p2/ddl/supplier.sql
Normal file
@ -0,0 +1,15 @@
|
||||
CREATE TABLE IF NOT EXISTS supplier (
|
||||
s_suppkey int NOT NULL,
|
||||
s_name VARCHAR(25) NOT NULL,
|
||||
s_address VARCHAR(40) NOT NULL,
|
||||
s_nationkey int NOT NULL,
|
||||
s_phone VARCHAR(15) NOT NULL,
|
||||
s_acctbal decimal(15, 2) NOT NULL,
|
||||
s_comment VARCHAR(101) NOT NULL
|
||||
)ENGINE=OLAP
|
||||
UNIQUE KEY(`s_suppkey`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`s_suppkey`) BUCKETS 12
|
||||
PROPERTIES (
|
||||
"replication_num" = "3"
|
||||
)
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM supplier where s_suppkey >= 0;
|
||||
@ -0,0 +1,6 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/supplier.tbl")
|
||||
INTO TABLE supplier
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(s_suppkey, s_name, s_address, s_nationkey, s_phone, s_acctbal, s_comment, temp)
|
||||
)
|
||||
@ -0,0 +1,7 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/supplier.tbl")
|
||||
INTO TABLE supplier
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(s_suppkey, s_name, s_address, s_nationkey, s_phone, s_acctbal, s_comment, temp)
|
||||
ORDER BY s_suppkey
|
||||
)
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM supplier where s_suppkey > 500000;
|
||||
@ -0,0 +1,16 @@
|
||||
CREATE TABLE IF NOT EXISTS supplier (
|
||||
s_suppkey int NOT NULL,
|
||||
s_name VARCHAR(25) NOT NULL,
|
||||
s_address VARCHAR(40) NOT NULL,
|
||||
s_nationkey int NOT NULL,
|
||||
s_phone VARCHAR(15) NOT NULL,
|
||||
s_acctbal decimal(15, 2) NOT NULL,
|
||||
s_comment VARCHAR(101) NOT NULL
|
||||
)ENGINE=OLAP
|
||||
UNIQUE KEY(`s_suppkey`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`s_suppkey`) BUCKETS 12
|
||||
PROPERTIES (
|
||||
"function_column.sequence_type" = 'int',
|
||||
"replication_num" = "3"
|
||||
)
|
||||
@ -0,0 +1,117 @@
|
||||
// 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_four_step") {
|
||||
|
||||
// Import multiple times, use unique key, use seq and delete, select some to delete, and then import
|
||||
// Map[tableName, rowCount]
|
||||
def tables = [nation: [25, 15], customer: [15000000, 7500000], lineitem: [600037902, 480038598], orders: [150000000, 120000000], part: [20000000, 10000000], partsupp: [80000000, 64000000], region: [5, 3], supplier: [1000000, 500000]]
|
||||
def s3BucketName = getS3BucketName()
|
||||
def s3WithProperties = """WITH S3 (
|
||||
|"AWS_ACCESS_KEY" = "${getS3AK()}",
|
||||
|"AWS_SECRET_KEY" = "${getS3SK()}",
|
||||
|"AWS_ENDPOINT" = "${getS3Endpoint()}",
|
||||
|"AWS_REGION" = "${getS3Region()}")
|
||||
|PROPERTIES(
|
||||
|"exec_mem_limit" = "8589934592",
|
||||
|"load_parallelism" = "3")""".stripMargin()
|
||||
// set fe configuration
|
||||
sql "ADMIN SET FRONTEND CONFIG ('max_bytes_per_broker_scanner' = '161061273600')"
|
||||
|
||||
|
||||
def uniqueID1 = Math.abs(UUID.randomUUID().hashCode()).toString()
|
||||
def uniqueID2 = Math.abs(UUID.randomUUID().hashCode()).toString()
|
||||
def uniqueID3 = Math.abs(UUID.randomUUID().hashCode()).toString()
|
||||
tables.each { table, rows ->
|
||||
sql """ DROP TABLE IF EXISTS $table """
|
||||
// create table if not exists
|
||||
sql new File("""${context.file.parent}/ddl/${table}_sequence.sql""").text
|
||||
def loadLabel1 = table + "_" + uniqueID1
|
||||
// load data from cos
|
||||
def loadSql1 = new File("""${context.file.parent}/ddl/${table}_load_sequence.sql""").text.replaceAll("\\\$\\{s3BucketName\\}", s3BucketName)
|
||||
loadSql1 = loadSql1.replaceAll("\\\$\\{loadLabel\\}", loadLabel1) + s3WithProperties
|
||||
sql loadSql1
|
||||
// check load state
|
||||
while (true) {
|
||||
def stateResult1 = sql "show load where Label = '${loadLabel1}'"
|
||||
def loadState1 = stateResult1[stateResult1.size() - 1][2].toString()
|
||||
if ("CANCELLED".equalsIgnoreCase(loadState1)) {
|
||||
throw new IllegalStateException("load ${loadLabel1} failed.")
|
||||
} else if ("FINISHED".equalsIgnoreCase(loadState1)) {
|
||||
sql 'sync'
|
||||
for (int i = 1; i <= 5; i++) {
|
||||
def loadRowCount = sql "select count(1) from ${table}"
|
||||
logger.info("select ${table} numbers: ${loadRowCount[0][0]}".toString())
|
||||
assertTrue(loadRowCount[0][0] == rows[0])
|
||||
}
|
||||
def loadLabel2 = table + "_" + uniqueID2
|
||||
def loadSql2 = new File("""${context.file.parent}/ddl/${table}_load_sequence.sql""").text.replaceAll("\\\$\\{s3BucketName\\}", s3BucketName)
|
||||
loadSql2 = loadSql2.replaceAll("\\\$\\{loadLabel\\}", loadLabel2) + s3WithProperties
|
||||
sql loadSql2
|
||||
|
||||
while (true) {
|
||||
def stateResult2 = sql "show load where Label = '${loadLabel2}'"
|
||||
def loadState2 = stateResult2[stateResult2.size() - 1][2].toString()
|
||||
if ("CANCELLED".equalsIgnoreCase(loadState2)) {
|
||||
throw new IllegalStateException("load ${loadLabel2} failed.")
|
||||
} else if ("FINISHED".equalsIgnoreCase(loadState2)) {
|
||||
sql 'sync'
|
||||
for (int i = 1; i <= 5; i++) {
|
||||
def loadRowCount = sql "select count(1) from ${table}"
|
||||
logger.info("select ${table} numbers: ${loadRowCount[0][0]}".toString())
|
||||
assertTrue(loadRowCount[0][0] == rows[0])
|
||||
}
|
||||
break;
|
||||
}
|
||||
sleep(5000)
|
||||
}
|
||||
|
||||
sql new File("""${context.file.parent}/ddl/${table}_part_delete.sql""").text
|
||||
sql 'sync'
|
||||
for (int i = 1; i <= 5; i++) {
|
||||
def loadRowCount = sql "select count(1) from ${table}"
|
||||
logger.info("select ${table} numbers: ${loadRowCount[0][0]}".toString())
|
||||
assertTrue(loadRowCount[0][0] == rows[1])
|
||||
}
|
||||
|
||||
def loadLabel3 = table + "_" + uniqueID3
|
||||
def loadSql3 = new File("""${context.file.parent}/ddl/${table}_load_sequence.sql""").text.replaceAll("\\\$\\{s3BucketName\\}", s3BucketName)
|
||||
loadSql3 = loadSql3.replaceAll("\\\$\\{loadLabel\\}", loadLabel3) + s3WithProperties
|
||||
sql loadSql3
|
||||
|
||||
while (true) {
|
||||
def stateResult3 = sql "show load where Label = '${loadLabel3}'"
|
||||
def loadState3 = stateResult3[stateResult3.size() - 1][2].toString()
|
||||
if ("CANCELLED".equalsIgnoreCase(loadState3)) {
|
||||
throw new IllegalStateException("load ${loadLabel3} failed.")
|
||||
} else if ("FINISHED".equalsIgnoreCase(loadState3)) {
|
||||
sql 'sync'
|
||||
for (int i = 1; i <= 5; i++) {
|
||||
def loadRowCount = sql "select count(1) from ${table}"
|
||||
logger.info("select ${table} numbers: ${loadRowCount[0][0]}".toString())
|
||||
assertTrue(loadRowCount[0][0] == rows[0])
|
||||
}
|
||||
break;
|
||||
}
|
||||
sleep(5000)
|
||||
}
|
||||
break
|
||||
}
|
||||
sleep(5000)
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,70 @@
|
||||
// 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") {
|
||||
|
||||
// Import once, use unique key, do not use seq and delete
|
||||
// Map[tableName, rowCount]
|
||||
def tables = [nation: 25, customer: 15000000, lineitem: 600037902, orders: 150000000, part: 20000000, partsupp: 80000000, region: 5, supplier: 1000000]
|
||||
def s3BucketName = getS3BucketName()
|
||||
def s3WithProperties = """WITH S3 (
|
||||
|"AWS_ACCESS_KEY" = "${getS3AK()}",
|
||||
|"AWS_SECRET_KEY" = "${getS3SK()}",
|
||||
|"AWS_ENDPOINT" = "${getS3Endpoint()}",
|
||||
|"AWS_REGION" = "${getS3Region()}")
|
||||
|PROPERTIES(
|
||||
|"exec_mem_limit" = "8589934592",
|
||||
|"load_parallelism" = "3")""".stripMargin()
|
||||
// set fe configuration
|
||||
sql "ADMIN SET FRONTEND CONFIG ('max_bytes_per_broker_scanner' = '161061273600')"
|
||||
|
||||
def uniqueID = Math.abs(UUID.randomUUID().hashCode()).toString()
|
||||
tables.each { table, rows ->
|
||||
sql """ DROP TABLE IF EXISTS $table """
|
||||
// create table if not exists
|
||||
sql new File("""${context.file.parent}/ddl/${table}.sql""").text
|
||||
def loadLabel = table + "_" + uniqueID
|
||||
// load data from cos
|
||||
def loadSql = new File("""${context.file.parent}/ddl/${table}_load.sql""").text.replaceAll("\\\$\\{s3BucketName\\}", s3BucketName)
|
||||
loadSql = loadSql.replaceAll("\\\$\\{loadLabel\\}", loadLabel) + s3WithProperties
|
||||
sql loadSql
|
||||
|
||||
// check load state
|
||||
while (true) {
|
||||
def stateResult = sql "show load where Label = '${loadLabel}'"
|
||||
def loadState = stateResult[stateResult.size() - 1][2].toString()
|
||||
if ("CANCELLED".equalsIgnoreCase(loadState)) {
|
||||
throw new IllegalStateException("load ${loadLabel} failed.")
|
||||
} else if ("FINISHED".equalsIgnoreCase(loadState)) {
|
||||
sql 'sync'
|
||||
for (int i = 1; i <= 5; i++) {
|
||||
def loadRowCount = sql "select count(1) from ${table}"
|
||||
logger.info("select ${table} numbers: ${loadRowCount[0][0]}".toString())
|
||||
assertTrue(loadRowCount[0][0] == rows)
|
||||
}
|
||||
sql new File("""${context.file.parent}/ddl/${table}_delete.sql""").text
|
||||
for (int i = 1; i <= 5; i++) {
|
||||
def loadRowCount = sql "select count(1) from ${table}"
|
||||
logger.info("select ${table} numbers: ${loadRowCount[0][0]}".toString())
|
||||
assertTrue(loadRowCount[0][0] == 0)
|
||||
}
|
||||
break
|
||||
}
|
||||
sleep(5000)
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,94 @@
|
||||
// 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") {
|
||||
|
||||
// Import multiple times, use unique key, use seq and delete
|
||||
// Map[tableName, rowCount]
|
||||
def tables = [nation: 25, customer: 15000000, lineitem: 600037902, orders: 150000000, part: 20000000, partsupp: 80000000, region: 5, supplier: 1000000]
|
||||
def s3BucketName = getS3BucketName()
|
||||
def s3WithProperties = """WITH S3 (
|
||||
|"AWS_ACCESS_KEY" = "${getS3AK()}",
|
||||
|"AWS_SECRET_KEY" = "${getS3SK()}",
|
||||
|"AWS_ENDPOINT" = "${getS3Endpoint()}",
|
||||
|"AWS_REGION" = "${getS3Region()}")
|
||||
|PROPERTIES(
|
||||
|"exec_mem_limit" = "8589934592",
|
||||
|"load_parallelism" = "3")""".stripMargin()
|
||||
// set fe configuration
|
||||
sql "ADMIN SET FRONTEND CONFIG ('max_bytes_per_broker_scanner' = '161061273600')"
|
||||
|
||||
|
||||
def uniqueID1 = Math.abs(UUID.randomUUID().hashCode()).toString()
|
||||
def uniqueID2 = Math.abs(UUID.randomUUID().hashCode()).toString()
|
||||
tables.each { table, rows ->
|
||||
sql """ DROP TABLE IF EXISTS $table """
|
||||
// create table if not exists
|
||||
sql new File("""${context.file.parent}/ddl/${table}_sequence.sql""").text
|
||||
def loadLabel1 = table + "_" + uniqueID1
|
||||
// load data from cos
|
||||
def loadSql1 = new File("""${context.file.parent}/ddl/${table}_load_sequence.sql""").text.replaceAll("\\\$\\{s3BucketName\\}", s3BucketName)
|
||||
loadSql1 = loadSql1.replaceAll("\\\$\\{loadLabel\\}", loadLabel1) + s3WithProperties
|
||||
sql loadSql1
|
||||
// check load state
|
||||
while (true) {
|
||||
def stateResult1 = sql "show load where Label = '${loadLabel1}'"
|
||||
def loadState1 = stateResult1[stateResult1.size() - 1][2].toString()
|
||||
if ("CANCELLED".equalsIgnoreCase(loadState1)) {
|
||||
throw new IllegalStateException("load ${loadLabel1} failed.")
|
||||
} else if ("FINISHED".equalsIgnoreCase(loadState1)) {
|
||||
sql 'sync'
|
||||
for (int i = 1; i <= 5; i++) {
|
||||
def loadRowCount = sql "select count(1) from ${table}"
|
||||
logger.info("select ${table} numbers: ${loadRowCount[0][0]}".toString())
|
||||
assertTrue(loadRowCount[0][0] == rows)
|
||||
}
|
||||
def loadLabel2 = table + "_" + uniqueID2
|
||||
def loadSql2 = new File("""${context.file.parent}/ddl/${table}_load_sequence.sql""").text.replaceAll("\\\$\\{s3BucketName\\}", s3BucketName)
|
||||
loadSql2 = loadSql2.replaceAll("\\\$\\{loadLabel\\}", loadLabel2) + s3WithProperties
|
||||
sql loadSql2
|
||||
|
||||
while (true) {
|
||||
def stateResult2 = sql "show load where Label = '${loadLabel2}'"
|
||||
def loadState2 = stateResult2[stateResult2.size() - 1][2].toString()
|
||||
if ("CANCELLED".equalsIgnoreCase(loadState2)) {
|
||||
throw new IllegalStateException("load ${loadLabel2} failed.")
|
||||
} else if ("FINISHED".equalsIgnoreCase(loadState2)) {
|
||||
sql 'sync'
|
||||
for (int i = 1; i <= 5; i++) {
|
||||
def loadRowCount = sql "select count(1) from ${table}"
|
||||
logger.info("select ${table} numbers: ${loadRowCount[0][0]}".toString())
|
||||
assertTrue(loadRowCount[0][0] == rows)
|
||||
}
|
||||
break;
|
||||
}
|
||||
sleep(5000)
|
||||
}
|
||||
|
||||
sql new File("""${context.file.parent}/ddl/${table}_delete.sql""").text
|
||||
sql 'sync'
|
||||
for (int i = 1; i <= 5; i++) {
|
||||
def loadRowCount = sql "select count(1) from ${table}"
|
||||
logger.info("select ${table} numbers: ${loadRowCount[0][0]}".toString())
|
||||
assertTrue(loadRowCount[0][0] == 0)
|
||||
}
|
||||
break
|
||||
}
|
||||
sleep(5000)
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,72 @@
|
||||
// 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") {
|
||||
|
||||
// Import once, use unique key, use seq and delete
|
||||
// Map[tableName, rowCount]
|
||||
def tables = [nation: 25, customer: 15000000, lineitem: 600037902, orders: 150000000, part: 20000000, partsupp: 80000000, region: 5, supplier: 1000000]
|
||||
def s3BucketName = getS3BucketName()
|
||||
def s3WithProperties = """WITH S3 (
|
||||
|"AWS_ACCESS_KEY" = "${getS3AK()}",
|
||||
|"AWS_SECRET_KEY" = "${getS3SK()}",
|
||||
|"AWS_ENDPOINT" = "${getS3Endpoint()}",
|
||||
|"AWS_REGION" = "${getS3Region()}")
|
||||
|PROPERTIES(
|
||||
|"exec_mem_limit" = "8589934592",
|
||||
|"load_parallelism" = "3")""".stripMargin()
|
||||
// set fe configuration
|
||||
sql "ADMIN SET FRONTEND CONFIG ('max_bytes_per_broker_scanner' = '161061273600')"
|
||||
|
||||
def uniqueID = Math.abs(UUID.randomUUID().hashCode()).toString()
|
||||
tables.each { table, rows ->
|
||||
sql """ DROP TABLE IF EXISTS $table """
|
||||
// create table if not exists
|
||||
sql new File("""${context.file.parent}/ddl/${table}_sequence.sql""").text
|
||||
|
||||
def loadLabel = table + "_" + uniqueID
|
||||
// load data from cos
|
||||
def loadSql = new File("""${context.file.parent}/ddl/${table}_load_sequence.sql""").text.replaceAll("\\\$\\{s3BucketName\\}", s3BucketName)
|
||||
loadSql = loadSql.replaceAll("\\\$\\{loadLabel\\}", loadLabel) + s3WithProperties
|
||||
sql loadSql
|
||||
|
||||
// check load state
|
||||
while (true) {
|
||||
def stateResult = sql "show load where Label = '${loadLabel}'"
|
||||
def loadState = stateResult[stateResult.size() - 1][2].toString()
|
||||
if ("CANCELLED".equalsIgnoreCase(loadState)) {
|
||||
throw new IllegalStateException("load ${loadLabel} failed.")
|
||||
} else if ("FINISHED".equalsIgnoreCase(loadState)) {
|
||||
sql 'sync'
|
||||
for (int i = 1; i <= 5; i++) {
|
||||
def loadRowCount = sql "select count(1) from ${table}"
|
||||
logger.info("select ${table} numbers: ${loadRowCount[0][0]}".toString())
|
||||
assertTrue(loadRowCount[0][0] == rows)
|
||||
}
|
||||
sql new File("""${context.file.parent}/ddl/${table}_delete.sql""").text
|
||||
sql 'sync'
|
||||
for (int i = 1; i <= 5; i++) {
|
||||
def loadRowCount = sql "select count(1) from ${table}"
|
||||
logger.info("select ${table} numbers: ${loadRowCount[0][0]}".toString())
|
||||
assertTrue(loadRowCount[0][0] == 0)
|
||||
}
|
||||
break
|
||||
}
|
||||
sleep(5000)
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,17 @@
|
||||
CREATE TABLE IF NOT EXISTS customer (
|
||||
c_custkey int NOT NULL,
|
||||
c_name VARCHAR(25) NOT NULL,
|
||||
c_address VARCHAR(40) NOT NULL,
|
||||
c_nationkey int NOT NULL,
|
||||
c_phone VARCHAR(15) NOT NULL,
|
||||
c_acctbal decimal(15, 2) NOT NULL,
|
||||
c_mktsegment VARCHAR(10) NOT NULL,
|
||||
c_comment VARCHAR(117) NOT NULL
|
||||
)ENGINE=OLAP
|
||||
UNIQUE KEY(`c_custkey`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`c_custkey`) BUCKETS 24
|
||||
PROPERTIES (
|
||||
"replication_num" = "3"
|
||||
)
|
||||
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM customer where C_CUSTKEY >= 0;
|
||||
@ -0,0 +1,6 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/customer.tbl")
|
||||
INTO TABLE customer
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(c_custkey, c_name, c_address, c_nationkey, c_phone, c_acctbal, c_mktsegment, c_comment, temp)
|
||||
)
|
||||
@ -0,0 +1,25 @@
|
||||
CREATE TABLE IF NOT EXISTS lineitem (
|
||||
l_shipdate DATE NOT NULL,
|
||||
l_orderkey bigint NOT NULL,
|
||||
l_linenumber int not null,
|
||||
l_partkey int NOT NULL,
|
||||
l_suppkey int not null,
|
||||
l_quantity decimal(15, 2) NOT NULL,
|
||||
l_extendedprice decimal(15, 2) NOT NULL,
|
||||
l_discount decimal(15, 2) NOT NULL,
|
||||
l_tax decimal(15, 2) NOT NULL,
|
||||
l_returnflag VARCHAR(1) NOT NULL,
|
||||
l_linestatus VARCHAR(1) NOT NULL,
|
||||
l_commitdate DATE NOT NULL,
|
||||
l_receiptdate DATE NOT NULL,
|
||||
l_shipinstruct VARCHAR(25) NOT NULL,
|
||||
l_shipmode VARCHAR(10) NOT NULL,
|
||||
l_comment VARCHAR(44) NOT NULL
|
||||
)ENGINE=OLAP
|
||||
UNIQUE KEY(`l_shipdate`, `l_orderkey`,`l_linenumber`,`l_partkey`,`l_suppkey`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`l_orderkey`) BUCKETS 96
|
||||
PROPERTIES (
|
||||
"replication_num" = "3"
|
||||
)
|
||||
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM lineitem where l_linenumber >= 0;
|
||||
@ -0,0 +1,6 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/lineitem.tbl.*")
|
||||
INTO TABLE lineitem
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(l_orderkey, l_partkey, l_suppkey, l_linenumber, l_quantity, l_extendedprice, l_discount, l_tax, l_returnflag,l_linestatus, l_shipdate,l_commitdate,l_receiptdate,l_shipinstruct,l_shipmode,l_comment,temp)
|
||||
)
|
||||
@ -0,0 +1,13 @@
|
||||
CREATE TABLE IF NOT EXISTS nation (
|
||||
`n_nationkey` int(11) NOT NULL,
|
||||
`n_name` varchar(25) NOT NULL,
|
||||
`n_regionkey` int(11) NOT NULL,
|
||||
`n_comment` varchar(152) NULL
|
||||
) ENGINE=OLAP
|
||||
UNIQUE KEY(`N_NATIONKEY`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`N_NATIONKEY`) BUCKETS 1
|
||||
PROPERTIES (
|
||||
"replication_num" = "3"
|
||||
);
|
||||
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM nation where n_nationkey >= 0;
|
||||
@ -0,0 +1,6 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/nation.tbl")
|
||||
INTO TABLE nation
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(n_nationkey, n_name, n_regionkey, n_comment, temp)
|
||||
)
|
||||
@ -0,0 +1,17 @@
|
||||
CREATE TABLE IF NOT EXISTS orders (
|
||||
o_orderkey bigint NOT NULL,
|
||||
o_orderdate DATE NOT NULL,
|
||||
o_custkey int NOT NULL,
|
||||
o_orderstatus VARCHAR(1) NOT NULL,
|
||||
o_totalprice decimal(15, 2) NOT NULL,
|
||||
o_orderpriority VARCHAR(15) NOT NULL,
|
||||
o_clerk VARCHAR(15) NOT NULL,
|
||||
o_shippriority int NOT NULL,
|
||||
o_comment VARCHAR(79) NOT NULL
|
||||
)ENGINE=OLAP
|
||||
UNIQUE KEY(`o_orderkey`, `o_orderdate`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`o_orderkey`) BUCKETS 96
|
||||
PROPERTIES (
|
||||
"replication_num" = "3"
|
||||
)
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM orders where o_orderkey >= 0;
|
||||
@ -0,0 +1,6 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/orders.tbl.*")
|
||||
INTO TABLE orders
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(o_orderkey, o_custkey, o_orderstatus, o_totalprice, o_orderdate, o_orderpriority, o_clerk, o_shippriority, o_comment, temp)
|
||||
)
|
||||
18
regression-test/suites/tpch_sf100_unique_sql_p2/ddl/part.sql
Normal file
18
regression-test/suites/tpch_sf100_unique_sql_p2/ddl/part.sql
Normal file
@ -0,0 +1,18 @@
|
||||
CREATE TABLE IF NOT EXISTS part (
|
||||
p_partkey int NOT NULL,
|
||||
p_name VARCHAR(55) NOT NULL,
|
||||
p_mfgr VARCHAR(25) NOT NULL,
|
||||
p_brand VARCHAR(10) NOT NULL,
|
||||
p_type VARCHAR(25) NOT NULL,
|
||||
p_size int NOT NULL,
|
||||
p_container VARCHAR(10) NOT NULL,
|
||||
p_retailprice decimal(15, 2) NOT NULL,
|
||||
p_comment VARCHAR(23) NOT NULL
|
||||
)ENGINE=OLAP
|
||||
UNIQUE KEY(`p_partkey`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`p_partkey`) BUCKETS 24
|
||||
PROPERTIES (
|
||||
"replication_num" = "3"
|
||||
)
|
||||
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM part where p_partkey >= 0;
|
||||
@ -0,0 +1,6 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/part.tbl")
|
||||
INTO TABLE part
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(p_partkey, p_name, p_mfgr, p_brand, p_type, p_size, p_container, p_retailprice, p_comment, temp)
|
||||
)
|
||||
@ -0,0 +1,14 @@
|
||||
CREATE TABLE IF NOT EXISTS partsupp (
|
||||
ps_partkey int NOT NULL,
|
||||
ps_suppkey int NOT NULL,
|
||||
ps_availqty int NOT NULL,
|
||||
ps_supplycost decimal(15, 2) NOT NULL,
|
||||
ps_comment VARCHAR(199) NOT NULL
|
||||
)ENGINE=OLAP
|
||||
UNIQUE KEY(`ps_partkey`,`ps_suppkey`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`ps_partkey`) BUCKETS 24
|
||||
PROPERTIES (
|
||||
"replication_num" = "3"
|
||||
)
|
||||
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM partsupp where ps_partkey >= 0;
|
||||
@ -0,0 +1,6 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/partsupp.tbl.*")
|
||||
INTO TABLE partsupp
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(ps_partkey, ps_suppkey, ps_availqty, ps_supplycost, ps_comment, temp)
|
||||
)
|
||||
@ -0,0 +1,12 @@
|
||||
CREATE TABLE IF NOT EXISTS region (
|
||||
r_regionkey int NOT NULL,
|
||||
r_name VARCHAR(25) NOT NULL,
|
||||
r_comment VARCHAR(152)
|
||||
)ENGINE=OLAP
|
||||
UNIQUE KEY(`r_regionkey`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`r_regionkey`) BUCKETS 1
|
||||
PROPERTIES (
|
||||
"replication_num" = "3"
|
||||
)
|
||||
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM region where r_regionkey >= 0;
|
||||
@ -0,0 +1,6 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/region.tbl")
|
||||
INTO TABLE region
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(r_regionkey, r_name, r_comment, temp)
|
||||
)
|
||||
@ -0,0 +1,15 @@
|
||||
CREATE TABLE IF NOT EXISTS supplier (
|
||||
s_suppkey int NOT NULL,
|
||||
s_name VARCHAR(25) NOT NULL,
|
||||
s_address VARCHAR(40) NOT NULL,
|
||||
s_nationkey int NOT NULL,
|
||||
s_phone VARCHAR(15) NOT NULL,
|
||||
s_acctbal decimal(15, 2) NOT NULL,
|
||||
s_comment VARCHAR(101) NOT NULL
|
||||
)ENGINE=OLAP
|
||||
UNIQUE KEY(`s_suppkey`)
|
||||
COMMENT "OLAP"
|
||||
DISTRIBUTED BY HASH(`s_suppkey`) BUCKETS 12
|
||||
PROPERTIES (
|
||||
"replication_num" = "3"
|
||||
)
|
||||
@ -0,0 +1 @@
|
||||
DELETE FROM supplier where s_suppkey >= 0;
|
||||
@ -0,0 +1,6 @@
|
||||
LOAD LABEL ${loadLabel} (
|
||||
DATA INFILE("s3://${s3BucketName}/regression/tpch/sf100/supplier.tbl")
|
||||
INTO TABLE supplier
|
||||
COLUMNS TERMINATED BY "|"
|
||||
(s_suppkey, s_name, s_address, s_nationkey, s_phone, s_acctbal, s_comment, temp)
|
||||
)
|
||||
71
regression-test/suites/tpch_sf100_unique_sql_p2/load.groovy
Normal file
71
regression-test/suites/tpch_sf100_unique_sql_p2/load.groovy
Normal file
@ -0,0 +1,71 @@
|
||||
// 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.
|
||||
|
||||
// syntax error:
|
||||
// q06 q13 q15
|
||||
// Test 23 suites, failed 3 suites
|
||||
|
||||
// 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") {
|
||||
// Map[tableName, rowCount]
|
||||
def tables = [customer: 15000000, lineitem: 600037902, nation: 25, orders: 150000000, part: 20000000, partsupp: 80000000, region: 5, supplier: 1000000]
|
||||
def s3BucketName = getS3BucketName()
|
||||
def s3WithProperties = """WITH S3 (
|
||||
|"AWS_ACCESS_KEY" = "${getS3AK()}",
|
||||
|"AWS_SECRET_KEY" = "${getS3SK()}",
|
||||
|"AWS_ENDPOINT" = "${getS3Endpoint()}",
|
||||
|"AWS_REGION" = "${getS3Region()}")
|
||||
|PROPERTIES(
|
||||
|"exec_mem_limit" = "8589934592",
|
||||
|"load_parallelism" = "3")""".stripMargin()
|
||||
// set fe configuration
|
||||
sql "ADMIN SET FRONTEND CONFIG ('max_bytes_per_broker_scanner' = '161061273600')"
|
||||
|
||||
def uniqueID = Math.abs(UUID.randomUUID().hashCode()).toString()
|
||||
tables.each { table, rows ->
|
||||
// create table if not exists
|
||||
sql new File("""${context.file.parent}/ddl/${table}.sql""").text
|
||||
// check row count
|
||||
def rowCount = sql "select count(*) from ${table}"
|
||||
if (rowCount[0][0] != rows) {
|
||||
def loadLabel = table + "_" + uniqueID
|
||||
sql new File("""${context.file.parent}/ddl/${table}_delete.sql""").text
|
||||
// load data from cos
|
||||
def loadSql = new File("""${context.file.parent}/ddl/${table}_load.sql""").text.replaceAll("\\\$\\{s3BucketName\\}", s3BucketName)
|
||||
loadSql = loadSql.replaceAll("\\\$\\{loadLabel\\}", loadLabel) + s3WithProperties
|
||||
sql loadSql
|
||||
|
||||
// check load state
|
||||
while (true) {
|
||||
def stateResult = sql "show load where Label = '${loadLabel}'"
|
||||
def loadState = stateResult[stateResult.size() - 1][2].toString()
|
||||
if ("CANCELLED".equalsIgnoreCase(loadState)) {
|
||||
throw new IllegalStateException("load ${loadLabel} failed.")
|
||||
} else if ("FINISHED".equalsIgnoreCase(loadState)) {
|
||||
break
|
||||
}
|
||||
sleep(5000)
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
23
regression-test/suites/tpch_sf100_unique_sql_p2/sql/q01.sql
Normal file
23
regression-test/suites/tpch_sf100_unique_sql_p2/sql/q01.sql
Normal file
@ -0,0 +1,23 @@
|
||||
-- tables: lineitem
|
||||
SELECT
|
||||
|
||||
l_returnflag,
|
||||
l_linestatus,
|
||||
sum(l_quantity) AS sum_qty,
|
||||
sum(l_extendedprice) AS sum_base_price,
|
||||
sum(l_extendedprice * (1 - l_discount)) AS sum_disc_price,
|
||||
sum(l_extendedprice * (1 - l_discount) * (1 + l_tax)) AS sum_charge,
|
||||
avg(l_quantity) AS avg_qty,
|
||||
avg(l_extendedprice) AS avg_price,
|
||||
avg(l_discount) AS avg_disc,
|
||||
count(*) AS count_order
|
||||
FROM
|
||||
lineitem
|
||||
WHERE
|
||||
l_shipdate <= DATE '1998-12-01' - INTERVAL '90' DAY
|
||||
GROUP BY
|
||||
l_returnflag,
|
||||
l_linestatus
|
||||
ORDER BY
|
||||
l_returnflag,
|
||||
l_linestatus
|
||||
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user