本篇内容包含如下几个部分:①背景介绍 ②环境准备 ③实操步骤 ④关键代码解析 ⑤效果验证
前4个部分内容略去,具体的准备过程参考老师发的指导文档,以及后期更新的指导文档,还有社区的关于flink的文章部分等相关内容。
可以参考如下链接:
Flink native Omnistream编译指导
安装Docker-安装基础环境-安装特性-OmniStream Flink Native化-OmniRuntime 特性指南-大数据-25.1.RC1-鲲鹏BoostKit历史版本开发文档-鲲鹏社区
本文主要针对使能和不使能OmniStream进行效果验证:
(一)测试文件
1、查询
SET sql-client.execution.result-mode=TABLEAU;
CREATE TABLE bid (
auction BIGINT,
bidder BIGINT,
price BIGINT,
`dateTime` TIMESTAMP(3),
extra VARCHAR
) WITH (
'connector' = 'filesystem',
'path' = '/usr/try/testdata/bid.csv',
'format' = 'csv'
);
SELECT auction, bidder, price, `dateTime`, extra FROM bid;
Bid.csv文件的内容如下:

2、inner join
SET sql-client.execution.result-mode=TABLEAU;
CREATE TABLE auction (
id BIGINT,
itemName VARCHAR,
`description` VARCHAR,
initialBid BIGINT,
reserve BIGINT,
`dateTime` TIMESTAMP(3),
expires TIMESTAMP(3),
seller BIGINT,
category BIGINT,
extra VARCHAR
) WITH (
'connector' = 'filesystem',
'path' = '/usr/try/testdata/auction_join.csv',
'format' = 'csv'
);
CREATE TABLE bid (
auction BIGINT,
bidder BIGINT,
price BIGINT,
channel VARCHAR,
`url` VARCHAR,
`dateTime` TIMESTAMP(3),
extra VARCHAR
) WITH (
'connector' = 'filesystem',
'path' = '/usr/try/testdata/bid_join.csv',
'format' = 'csv'
);
SELECT auction, bidder, price, channel, `url`, B.`dateTime`, B.extra,itemName, `description`, initialBid, reserve, A.`dateTime`, expires, seller, category, A.extra FROM bid AS B INNER JOIN auction AS A on B.auction = A.id WHERE A.category = 10;
auction_join.csv文件的内容如下:

bid_join.csv文件的内容如下:

(二)使能OmniStream,Flink的输出结果:
1、查询
+I,0,2001,27728,2025-02-07 12:00:00.000,srqmoMZ]\^RxdgyrcswdhyuKLTZYVSKUXT[XTHXT^fcaljw_MY\HW^VRa[awezulaH_\
+I,1002,2001,76090,2025-02-07 12:00:00.000,jczcZHTNUMUP\[YQMJJNSURKRYNJfenixcH_LXT]JN_\HYILUHWaSHKHQQ[]Z_MILYV]UUUY]
+I,1000,2001,32252699,2025-02-07 12:00:00.000,zjjaxaYQWLHcfjpkyntbzpjPTaW`Qxydeyr^^X\[LTWHLQJwaekebtdnimfjemxalIV]P_Xu

2、inner join
+I,1001,2001,1239,Apple,https://www.nexmark.com/h_kk/_gw/gdx/item.htm?1,2024-11-18 23:40:15.245,'nLQMLOO`aU`NX]RaVUHvpisrv[NRVJLqpelhfqwcfywuwisfxrqyaa','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1001,2001,630242,Apple,https://www.nexmark.com/h_kk/_gw/gdx/item.htm?1,2024-11-18 23:40:15.246,'qjxuvrukyboXKHRJ_sswfojJWWSPJbippynyvupgbMQZ^KHS\QMTZgwufnvrx','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1009,2007,99929,channel-5976,https://www.nexmark.com/zlma/qkzq/cbbs/item.htm?1&channel_451411968,2024-11-18 23:40:15.246,'ijnhtkkyQPNPTKvsdbmdilfxtp[_TO_]mxigjeUQMHY`S\NW`SckxksaH]Q^','cojoytls','zxdlpppmzh iyvnziaoeiwdrmxfaxtfgfbwaxosvsgnzfqvukaojkl',1816492,39913427,2024-11-18 23:40:15.260,2024-11-18 23:40:15.326,1000,10,'efcyojMMPRWMtjjzoaOWSOXReujglyS\T[O]ancbavfkrryeehzxljjnpoqjhrxwknapwmhkYVMJZPI][`\JMHHaSLwgqgoblwjfclIR]MVLnpapagxptlusSIVXYYYS[HN`yhhsyxrisfuuNQMN`Vxqvlpfiwljveshvtbm[J^OP[TXIX_Y\PU^PYnfuuatILXVHPdporhyLY[W^]pawopdUXOUL`dziest_ON_YRIXR`S`NIM\`HgwskfvRXUX_ItdiseqPYJV]\JIU^JWL_VTTSHUZH`QZP\SKNgwmjvjWaR]NLqrlbzjekpuhaI\O`_P][WZLZlxmqwygvrmutUPRLUatqkursYW[^MSL[IMTNppkpsffyrskmpmbwazQaJVVZVU`YHOsrktacQa_LNSo'
+I,1001,2001,13418420,Facebook,https://www.nexmark.com/_uzh/cfp/iph/item.htm?1,2024-11-18 23:40:15.248,'RYSKLokenpbNIVQIR\[LQIZxuttwfVKUQYKY\YH`MncaibpLZJ^WUHHLHNIuuivetenjsofouwcntZRa','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1003,2001,763,Baidu,https://www.nexmark.com/csvp/nvi_/vrn_/item.htm?1,2024-11-18 23:40:15.250,'optfcIXR_]`JVVVUHMMNKM]ZWa]VI]SSMJ_V\VSLO^`TTQHYUXNRalttiwjpmqotkxqunitK]aW_US[JP','avbot','w xxucexnoskk lxg iiysvxbxbtucppnvpvnipsrmsv',5766,130240,2024-11-18 23:40:15.250,2024-11-18 23:40:15.542,1000,10,'qxeaymungaovafcIOPV`XmwvvsbN\MRMM_S_RUQ`L^HK_QT`PXPM_SaLUpmsuelfqighjxdaeqgkukoxbjvipjqkdmmbhnvdnobxccwygPHL[I_rbqaozyyhkyfidymtlHU_ZLIfgisxgKL]YIOmwhgebogtdymS\aZIXRNWZIPsddkbmNKL`MTZ\^XVaITKQVZqigxntRNPRXOpjuqntUQJ_J\jpsxwdpdbxitfeekypOKU^_Q\`WVQ^ITMKIQnsuxwdqpjwzaqfijwkQTZKQMJM^MPMdhfcxvunrvtbpvbidnkfeplzZVZVaJ_`HHR]S[I[USOPWXS_`W[aQZWUTJ_aulxvaykvgsai^VZaYPrtwodpwuyijdivzamaa'
+I,1009,2008,24520,Baidu,https://www.nexmark.com/csvp/nvi_/vrn_/item.htm?1,2024-11-18 23:40:15.251,'XQyiuzvwlfotivZ]T^RQISKLWXdxgqjnkakrnl^IR_TMI^NN^U`Y^IOWvwxtkjvwoivnaRU[[','cojoytls','zxdlpppmzh iyvnziaoeiwdrmxfaxtfgfbwaxosvsgnzfqvukaojkl',1816492,39913427,2024-11-18 23:40:15.260,2024-11-18 23:40:15.326,1000,10,'efcyojMMPRWMtjjzoaOWSOXReujglyS\T[O]ancbavfkrryeehzxljjnpoqjhrxwknapwmhkYVMJZPI][`\JMHHaSLwgqgoblwjfclIR]MVLnpapagxptlusSIVXYYYS[HN`yhhsyxrisfuuNQMN`Vxqvlpfiwljveshvtbm[J^OP[TXIX_Y\PU^PYnfuuatILXVHPdporhyLY[W^]pawopdUXOUL`dziest_ON_YRIXR`S`NIM\`HgwskfvRXUX_ItdiseqPYJV]\JIU^JWL_VTTSHUZH`QZP\SKNgwmjvjWaR]NLqrlbzjekpuhaI\O`_P][WZLZlxmqwygvrmutUPRLUatqkursYW[^MSL[IMTNppkpsffyrskmpmbwazQaJVVZVU`YHOsrktacQa_LNSo'
+I,1001,2001,585,channel-2046,https://www.nexmark.com/u_m/gdd/svxp/item.htm?1&channel_2145386496,2024-11-18 23:40:15.252,'fwchzvjscbnomknzrzaaMPLRU`WKW]\Ttaftut\]HUW\HWSLWXKNPISJjwieapX\RPPKT`]Z]L^TVH','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1001,2001,26772,channel-2390,https://www.nexmark.com/pvq/ozia/_vjx/item.htm?1&channel_1787822080,2024-11-18 23:40:15.252,'NLHYNXiafrtmSP[HM^nwnrrmJV^^XSXQZN[\QYZ\_VnratxtXI`IXJpskgprfila','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1001,2001,2400,channel-6775,https://www.nexmark.com/qbar/gmdm/_utm/item.htm?1&channel_296222720,2024-11-18 23:40:15.253,'axaN\TP_[_ZP^aedhebvL]XPUZKU`YHTyxzkrtlloxfa_QMKKQpqtf','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1003,2001,11532882,Apple,https://www.nexmark.com/h_kk/_gw/gdx/item.htm?1,2024-11-18 23:40:15.253,'SWX`XaV_H^ugpdim^YZVSRvgkourugreadbewircezfqxhYRJ\XNX]Ha_IWXL[^','avbot','w xxucexnoskk lxg iiysvxbxbtucppnvpvnipsrmsv',5766,130240,2024-11-18 23:40:15.250,2024-11-18 23:40:15.542,1000,10,'qxeaymungaovafcIOPV`XmwvvsbN\MRMM_S_RUQ`L^HK_QT`PXPM_SaLUpmsuelfqighjxdaeqgkukoxbjvipjqkdmmbhnvdnobxccwygPHL[I_rbqaozyyhkyfidymtlHU_ZLIfgisxgKL]YIOmwhgebogtdymS\aZIXRNWZIPsddkbmNKL`MTZ\^XVaITKQVZqigxntRNPRXOpjuqntUQJ_J\jpsxwdpdbxitfeekypOKU^_Q\`WVQ^ITMKIQnsuxwdqpjwzaqfijwkQTZKQMJM^MPMdhfcxvunrvtbpvbidnkfeplzZVZVaJ_`HHR]S[I[USOPWXS_`W[aQZWUTJ_aulxvaykvgsai^VZaYPrtwodpwuyijdivzamaa'
+I,1001,2001,57296119,channel-3509,https://www.nexmark.com/fkwg/ar_/kccl/item.htm?1,2024-11-18 23:40:15.255,'cU]_NW[kzxqxgywoqjlndmdvrqcflsfOS^aXKsylvkiRNLZ][ltbxkkosesjwaiplwgQZa`WYPI','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1001,2001,25973940,channel-2927,https://www.nexmark.com/fuh/dwca/wrt/item.htm?1&channel_154140672,2024-11-18 23:40:15.256,'mmyenkvejnxgmguggtggzwyjvpxftbwVMUL_IxbokdoTIYU`Oukbsbnjailqfeyc','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1001,2007,2761119,Google,https://www.nexmark.com/cgwt/qfwx/jgd/item.htm?1,2024-11-18 23:40:15.257,'UPJfqarpantazaaKaTRTTnitdkvaMUP\_[``NJSkrneovhhfnla`UNU`[JOVWP_itwsvyhu','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1001,2001,219832,Facebook,https://www.nexmark.com/_uzh/cfp/iph/item.htm?1,2024-11-18 23:40:15.258,'PXHVIS[Y[TZVjaolzcT^IM^P^QI\KYvfiqytqrxknwxlvrsrxjrnse\RHJ`VXJOW`X','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1018,2001,78754275,Facebook,https://www.nexmark.com/_uzh/cfp/iph/item.htm?1,2024-11-18 23:40:15.258,'odxUM^YI^MYW^aMrmjywtwoykzatwfyyuoamlfeTL`Z`]_R`NLXRR^_QXkubyktSHP[O]fegb','nidomjbqcz mw m tkf','rkkd kk',1188,5604,2024-11-18 23:40:15.275,2024-11-18 23:40:15.505,1000,10,'VSOUQtewgsldjzrihTMSVJWOJWIZJwhuguy\_KTRaN_HOIHpxbwqbHPLUSIJYJH\VLYH^L]fauycadsqgeijmnxpqJ`U`MQpgvmfv]IPaaSpzrziiX^T[HNsgqhnvirlzkthlcxacaVaIWWtuywfixwydxsyymsexweyotubkqmpnNS[H]PutilaiYLWTNJraxtetVVY`]Q]UR__MrlxlafvsftsiylmrozY[YYTYgxerwvflkxwjZ`JI]U`RNU`Vijflou[XaV\T\S_YaWTPSYV`YNUOY`QWNXQNrngdezexjpewkxhocrphxcnanxrcgfzbtmwcbkylwcigrlvx'
+I,1018,2001,309004,Google,https://www.nexmark.com/cgwt/qfwx/jgd/item.htm?1,2024-11-18 23:40:15.259,'HTP^M[[ZVQVIZXUWzqooaaHLQH\UJNMN[LZ_MYJQzwteovmratfhY[JSTKQaYQL]SVWQSOgespss[IRV','nidomjbqcz mw m tkf','rkkd kk',1188,5604,2024-11-18 23:40:15.275,2024-11-18 23:40:15.505,1000,10,'VSOUQtewgsldjzrihTMSVJWOJWIZJwhuguy\_KTRaN_HOIHpxbwqbHPLUSIJYJH\VLYH^L]fauycadsqgeijmnxpqJ`U`MQpgvmfv]IPaaSpzrziiX^T[HNsgqhnvirlzkthlcxacaVaIWWtuywfixwydxsyymsexweyotubkqmpnNS[H]PutilaiYLWTNJraxtetVVY`]Q]UR__MrlxlafvsftsiylmrozY[YYTYgxerwvflkxwjZ`JI]U`RNU`Vijflou[XaV\T\S_YaWTPSYV`YNUOY`QWNXQNrngdezexjpewkxhocrphxcnanxrcgfzbtmwcbkylwcigrlvx'
+I,1001,2005,26249,Apple,https://www.nexmark.com/h_kk/_gw/gdx/item.htm?1,2024-11-18 23:40:15.260,'lvckbufxwgzJ_S[JOpmanoxqpapsahsgidrqxnbcriykhssSSXHKMLXST^XX_TUS^T','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1001,2001,5905969,Google,https://www.nexmark.com/cgwt/qfwx/jgd/item.htm?1,2024-11-18 23:40:15.261,'RLN\OKa\J_YPQTXbtrjbyiecxdcMYKMZ\UNKUaNVXLMQS]UYL]TcvynpdW_\]JJ]ZVS\RKY','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1018,2002,4689,Facebook,https://www.nexmark.com/_uzh/cfp/iph/item.htm?1,2024-11-18 23:40:15.262,'i\_KKX]ajvppicvogbawzspyhX]]O`WLVXQLa^P^KYIJZMP]SyczaifPQ]^Y^VWO]U\YNKU\[aa_L','nidomjbqcz mw m tkf','rkkd kk',1188,5604,2024-11-18 23:40:15.275,2024-11-18 23:40:15.505,1000,10,'VSOUQtewgsldjzrihTMSVJWOJWIZJwhuguy\_KTRaN_HOIHpxbwqbHPLUSIJYJH\VLYH^L]fauycadsqgeijmnxpqJ`U`MQpgvmfv]IPaaSpzrziiX^T[HNsgqhnvirlzkthlcxacaVaIWWtuywfixwydxsyymsexweyotubkqmpnNS[H]PutilaiYLWTNJraxtetVVY`]Q]UR__MrlxlafvsftsiylmrozY[YYTYgxerwvflkxwjZ`JI]U`RNU`Vijflou[XaV\T\S_YaWTPSYV`YNUOY`QWNXQNrngdezexjpewkxhocrphxcnanxrcgfzbtmwcbkylwcigrlvx'
+I,1018,2007,16710,channel-3341,https://www.nexmark.com/p_y/ohfv/xmlc/item.htm?1&channel_1330642944,2024-11-18 23:40:15.262,'JJKvqreqnsmqpdoUVS`_KTRVPWMJNJVTZcsinphcuodcn]MVPQ\ZZZL^WaY_SLMaaUSITjnasltobmim','nidomjbqcz mw m tkf','rkkd kk',1188,5604,2024-11-18 23:40:15.275,2024-11-18 23:40:15.505,1000,10,'VSOUQtewgsldjzrihTMSVJWOJWIZJwhuguy\_KTRaN_HOIHpxbwqbHPLUSIJYJH\VLYH^L]fauycadsqgeijmnxpqJ`U`MQpgvmfv]IPaaSpzrziiX^T[HNsgqhnvirlzkthlcxacaVaIWWtuywfixwydxsyymsexweyotubkqmpnNS[H]PutilaiYLWTNJraxtetVVY`]Q]UR__MrlxlafvsftsiylmrozY[YYTYgxerwvflkxwjZ`JI]U`RNU`Vijflou[XaV\T\S_YaWTPSYV`YNUOY`QWNXQNrngdezexjpewkxhocrphxcnanxrcgfzbtmwcbkylwcigrlvx'
+I,1009,2001,436,Facebook,https://www.nexmark.com/_uzh/cfp/iph/item.htm?1,2024-11-18 23:40:15.263,'ubhjrwfqafgcrxuHOSM]Wvynhjbucavvz\^ZMHXqlfgqnHN^^NXRIHM]Y][^UTKzrgz','cojoytls','zxdlpppmzh iyvnziaoeiwdrmxfaxtfgfbwaxosvsgnzfqvukaojkl',1816492,39913427,2024-11-18 23:40:15.260,2024-11-18 23:40:15.326,1000,10,'efcyojMMPRWMtjjzoaOWSOXReujglyS\T[O]ancbavfkrryeehzxljjnpoqjhrxwknapwmhkYVMJZPI][`\JMHHaSLwgqgoblwjfclIR]MVLnpapagxptlusSIVXYYYS[HN`yhhsyxrisfuuNQMN`Vxqvlpfiwljveshvtbm[J^OP[TXIX_Y\PU^PYnfuuatILXVHPdporhyLY[W^]pawopdUXOUL`dziest_ON_YRIXR`S`NIM\`HgwskfvRXUX_ItdiseqPYJV]\JIU^JWL_VTTSHUZH`QZP\SKNgwmjvjWaR]NLqrlbzjekpuhaI\O`_P][WZLZlxmqwygvrmutUPRLUatqkursYW[^MSL[IMTNppkpsffyrskmpmbwazQaJVVZVU`YHOsrktacQa_LNSo'
+I,1003,2001,90030880,Facebook,https://www.nexmark.com/_uzh/cfp/iph/item.htm?1,2024-11-18 23:40:15.264,'[PQO]HHLKMQW^O\LJINtihiklfczkhm_RNPM\bbztllntcwhw^O\^^\]\K]PTcr','avbot','w xxucexnoskk lxg iiysvxbxbtucppnvpvnipsrmsv',5766,130240,2024-11-18 23:40:15.250,2024-11-18 23:40:15.542,1000,10,'qxeaymungaovafcIOPV`XmwvvsbN\MRMM_S_RUQ`L^HK_QT`PXPM_SaLUpmsuelfqighjxdaeqgkukoxbjvipjqkdmmbhnvdnobxccwygPHL[I_rbqaozyyhkyfidymtlHU_ZLIfgisxgKL]YIOmwhgebogtdymS\aZIXRNWZIPsddkbmNKL`MTZ\^XVaITKQVZqigxntRNPRXOpjuqntUQJ_J\jpsxwdpdbxitfeekypOKU^_Q\`WVQ^ITMKIQnsuxwdqpjwzaqfijwkQTZKQMJM^MPMdhfcxvunrvtbpvbidnkfeplzZVZVaJ_`HHR]S[I[USOPWXS_`W[aQZWUTJ_aulxvaykvgsai^VZaYPrtwodpwuyijdivzamaa'


(三)不使能OmniStream,Flink的输出结果:
1、查询
Flink SQL> +----+----------------------+----------------------+----------------------+-------------------------+--------------------------------+
| op | auction | bidder | price | dateTime | extra |
+----+----------------------+----------------------+----------------------+-------------------------+--------------------------------+
| +I | 0 | 2001 | 27728 | 2025-02-07 12:00:00.000 | srqmoMZ]\^RxdgyrcswdhyuKLTZ... |
| +I | 1002 | 2001 | 76090 | 2025-02-07 12:00:00.000 | jczcZHTNUMUP\[YQMJJNSURKRYN... |
| +I | 1000 | 2001 | 32252699 | 2025-02-07 12:00:00.000 | zjjaxaYQWLHcfjpkyntbzpjPTaW... |
+----+----------------------+----------------------+----------------------+-------------------------+--------------------------------+

2、inner join
Flink SQL> +----+----------------------+----------------------+----------------------+--------------------------------+--------------------------------+-------------------------+--------------------------------+--------------------------------+--------------------------------+----------------------+----------------------+-------------------------+-------------------------+----------------------+----------------------+--------------------------------+
| op | auction | bidder | price | channel | url | dateTime | extra | itemName | description | initialBid | reserve | dateTime0 | expires | seller | category | extra0 |
+----+----------------------+----------------------+----------------------+--------------------------------+--------------------------------+-------------------------+--------------------------------+--------------------------------+--------------------------------+----------------------+----------------------+-------------------------+-------------------------+----------------------+----------------------+--------------------------------+
| +I | 1001 | 2001 | 585 | channel-2046 | https://www.nexmark.com/u_m... | 2024-11-18 23:40:15.252 | 'fwchzvjscbnomknzrzaaMPLRU`... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1001 | 2001 | 26772 | channel-2390 | https://www.nexmark.com/pvq... | 2024-11-18 23:40:15.252 | 'NLHYNXiafrtmSP[HM^nwnrrmJV... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1001 | 2001 | 25973940 | channel-2927 | https://www.nexmark.com/fuh... | 2024-11-18 23:40:15.256 | 'mmyenkvejnxgmguggtggzwyjvp... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1001 | 2001 | 219832 | Facebook | https://www.nexmark.com/_uz... | 2024-11-18 23:40:15.258 | 'PXHVIS[Y[TZVjaolzcT^IM^P^Q... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1001 | 2007 | 2761119 | Google | https://www.nexmark.com/cgw... | 2024-11-18 23:40:15.257 | 'UPJfqarpantazaaKaTRTTnitdk... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1001 | 2001 | 630242 | Apple | https://www.nexmark.com/h_k... | 2024-11-18 23:40:15.246 | 'qjxuvrukyboXKHRJ_sswfojJWW... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1001 | 2001 | 1239 | Apple | https://www.nexmark.com/h_k... | 2024-11-18 23:40:15.245 | 'nLQMLOO`aU`NX]RaVUHvpisrv[... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1001 | 2001 | 2400 | channel-6775 | https://www.nexmark.com/qba... | 2024-11-18 23:40:15.253 | 'axaN\TP_[_ZP^aedhebvL]XPUZ... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1001 | 2001 | 57296119 | channel-3509 | https://www.nexmark.com/fkw... | 2024-11-18 23:40:15.255 | 'cU]_NW[kzxqxgywoqjlndmdvrq... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1001 | 2005 | 26249 | Apple | https://www.nexmark.com/h_k... | 2024-11-18 23:40:15.260 | 'lvckbufxwgzJ_S[JOpmanoxqpa... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1001 | 2001 | 13418420 | Facebook | https://www.nexmark.com/_uz... | 2024-11-18 23:40:15.248 | 'RYSKLokenpbNIVQIR\[LQIZxut... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1003 | 2001 | 11532882 | Apple | https://www.nexmark.com/h_k... | 2024-11-18 23:40:15.253 | 'SWX`XaV_H^ugpdim^YZVSRvgko... | 'avbot' | 'w xxucexnoskk lxg iiysvxbx... | 5766 | 130240 | 2024-11-18 23:40:15.250 | 2024-11-18 23:40:15.542 | 1000 | 10 | 'qxeaymungaovafcIOPV`Xmwvvs... |
| +I | 1003 | 2001 | 763 | Baidu | https://www.nexmark.com/csv... | 2024-11-18 23:40:15.250 | 'optfcIXR_]`JVVVUHMMNKM]ZWa... | 'avbot' | 'w xxucexnoskk lxg iiysvxbx... | 5766 | 130240 | 2024-11-18 23:40:15.250 | 2024-11-18 23:40:15.542 | 1000 | 10 | 'qxeaymungaovafcIOPV`Xmwvvs... |
| +I | 1009 | 2007 | 99929 | channel-5976 | https://www.nexmark.com/zlm... | 2024-11-18 23:40:15.246 | 'ijnhtkkyQPNPTKvsdbmdilfxtp... | 'cojoytls' | 'zxdlpppmzh iyvnziaoeiwdrmx... | 1816492 | 39913427 | 2024-11-18 23:40:15.260 | 2024-11-18 23:40:15.326 | 1000 | 10 | 'efcyojMMPRWMtjjzoaOWSOXReu... |
| +I | 1009 | 2008 | 24520 | Baidu | https://www.nexmark.com/csv... | 2024-11-18 23:40:15.251 | 'XQyiuzvwlfotivZ]T^RQISKLWX... | 'cojoytls' | 'zxdlpppmzh iyvnziaoeiwdrmx... | 1816492 | 39913427 | 2024-11-18 23:40:15.260 | 2024-11-18 23:40:15.326 | 1000 | 10 | 'efcyojMMPRWMtjjzoaOWSOXReu... |
| +I | 1001 | 2001 | 5905969 | Google | https://www.nexmark.com/cgw... | 2024-11-18 23:40:15.261 | 'RLN\OKa\J_YPQTXbtrjbyiecxd... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1018 | 2001 | 78754275 | Facebook | https://www.nexmark.com/_uz... | 2024-11-18 23:40:15.258 | 'odxUM^YI^MYW^aMrmjywtwoykz... | 'nidomjbqcz mw m tkf' | 'rkkd kk' | 1188 | 5604 | 2024-11-18 23:40:15.275 | 2024-11-18 23:40:15.505 | 1000 | 10 | 'VSOUQtewgsldjzrihTMSVJWOJW... |
| +I | 1018 | 2001 | 309004 | Google | https://www.nexmark.com/cgw... | 2024-11-18 23:40:15.259 | 'HTP^M[[ZVQVIZXUWzqooaaHLQH... | 'nidomjbqcz mw m tkf' | 'rkkd kk' | 1188 | 5604 | 2024-11-18 23:40:15.275 | 2024-11-18 23:40:15.505 | 1000 | 10 | 'VSOUQtewgsldjzrihTMSVJWOJW... |
| +I | 1018 | 2002 | 4689 | Facebook | https://www.nexmark.com/_uz... | 2024-11-18 23:40:15.262 | 'i\_KKX]ajvppicvogbawzspyhX... | 'nidomjbqcz mw m tkf' | 'rkkd kk' | 1188 | 5604 | 2024-11-18 23:40:15.275 | 2024-11-18 23:40:15.505 | 1000 | 10 | 'VSOUQtewgsldjzrihTMSVJWOJW... |
| +I | 1018 | 2007 | 16710 | channel-3341 | https://www.nexmark.com/p_y... | 2024-11-18 23:40:15.262 | 'JJKvqreqnsmqpdoUVS`_KTRVPW... | 'nidomjbqcz mw m tkf' | 'rkkd kk' | 1188 | 5604 | 2024-11-18 23:40:15.275 | 2024-11-18 23:40:15.505 | 1000 | 10 | 'VSOUQtewgsldjzrihTMSVJWOJW... |
| +I | 1009 | 2001 | 436 | Facebook | https://www.nexmark.com/_uz... | 2024-11-18 23:40:15.263 | 'ubhjrwfqafgcrxuHOSM]Wvynhj... | 'cojoytls' | 'zxdlpppmzh iyvnziaoeiwdrmx... | 1816492 | 39913427 | 2024-11-18 23:40:15.260 | 2024-11-18 23:40:15.326 | 1000 | 10 | 'efcyojMMPRWMtjjzoaOWSOXReu... |
| +I | 1003 | 2001 | 90030880 | Facebook | https://www.nexmark.com/_uz... | 2024-11-18 23:40:15.264 | '[PQO]HHLKMQW^O\LJINtihiklf... | 'avbot' | 'w xxucexnoskk lxg iiysvxbx... | 5766 | 130240 | 2024-11-18 23:40:15.250 | 2024-11-18 23:40:15.542 | 1000 | 10 | 'qxeaymungaovafcIOPV`Xmwvvs... |
+----+----------------------+----------------------+----------------------+--------------------------------+--------------------------------+-------------------------+--------------------------------+--------------------------------+--------------------------------+----------------------+----------------------+-------------------------+-------------------------+----------------------+----------------------+--------------------------------+
Received a total of 22 rows

(四)结论
经过数据对比,虽然显示格式上稍有差别,但数据内容基本一致。至此,使能OmniStream的场景验证完毕。
本篇内容包含如下几个部分:①背景介绍 ②环境准备 ③实操步骤 ④关键代码解析 ⑤效果验证
前4个部分内容略去,具体的准备过程参考老师发的指导文档,以及后期更新的指导文档,还有社区的关于flink的文章部分等相关内容。
可以参考如下链接:
Flink native Omnistream编译指导
安装Docker-安装基础环境-安装特性-OmniStream Flink Native化-OmniRuntime 特性指南-大数据-25.1.RC1-鲲鹏BoostKit历史版本开发文档-鲲鹏社区
本文主要针对使能和不使能OmniStream进行效果验证:
(一)测试文件
1、查询
SET sql-client.execution.result-mode=TABLEAU;
CREATE TABLE bid (
auction BIGINT,
bidder BIGINT,
price BIGINT,
`dateTime` TIMESTAMP(3),
extra VARCHAR
) WITH (
'connector' = 'filesystem',
'path' = '/usr/try/testdata/bid.csv',
'format' = 'csv'
);
SELECT auction, bidder, price, `dateTime`, extra FROM bid;
Bid.csv文件的内容如下:
2、inner join
SET sql-client.execution.result-mode=TABLEAU;
CREATE TABLE auction (
id BIGINT,
itemName VARCHAR,
`description` VARCHAR,
initialBid BIGINT,
reserve BIGINT,
`dateTime` TIMESTAMP(3),
expires TIMESTAMP(3),
seller BIGINT,
category BIGINT,
extra VARCHAR
) WITH (
'connector' = 'filesystem',
'path' = '/usr/try/testdata/auction_join.csv',
'format' = 'csv'
);
CREATE TABLE bid (
auction BIGINT,
bidder BIGINT,
price BIGINT,
channel VARCHAR,
`url` VARCHAR,
`dateTime` TIMESTAMP(3),
extra VARCHAR
) WITH (
'connector' = 'filesystem',
'path' = '/usr/try/testdata/bid_join.csv',
'format' = 'csv'
);
SELECT auction, bidder, price, channel, `url`, B.`dateTime`, B.extra,itemName, `description`, initialBid, reserve, A.`dateTime`, expires, seller, category, A.extra FROM bid AS B INNER JOIN auction AS A on B.auction = A.id WHERE A.category = 10;
auction_join.csv文件的内容如下:
bid_join.csv文件的内容如下:
(二)使能OmniStream,Flink的输出结果:
1、查询
+I,0,2001,27728,2025-02-07 12:00:00.000,srqmoMZ]\^RxdgyrcswdhyuKLTZYVSKUXT[XTHXT^fcaljw_MY\HW^VRa[awezulaH_\
+I,1002,2001,76090,2025-02-07 12:00:00.000,jczcZHTNUMUP\[YQMJJNSURKRYNJfenixcH_LXT]JN_\HYILUHWaSHKHQQ[]Z_MILYV]UUUY]
+I,1000,2001,32252699,2025-02-07 12:00:00.000,zjjaxaYQWLHcfjpkyntbzpjPTaW`Qxydeyr^^X\[LTWHLQJwaekebtdnimfjemxalIV]P_Xu
2、inner join
+I,1001,2001,1239,Apple,https://www.nexmark.com/h_kk/_gw/gdx/item.htm?1,2024-11-18 23:40:15.245,'nLQMLOO`aU`NX]RaVUHvpisrv[NRVJLqpelhfqwcfywuwisfxrqyaa','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1001,2001,630242,Apple,https://www.nexmark.com/h_kk/_gw/gdx/item.htm?1,2024-11-18 23:40:15.246,'qjxuvrukyboXKHRJ_sswfojJWWSPJbippynyvupgbMQZ^KHS\QMTZgwufnvrx','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1009,2007,99929,channel-5976,https://www.nexmark.com/zlma/qkzq/cbbs/item.htm?1&channel_451411968,2024-11-18 23:40:15.246,'ijnhtkkyQPNPTKvsdbmdilfxtp[_TO_]mxigjeUQMHY`S\NW`SckxksaH]Q^','cojoytls','zxdlpppmzh iyvnziaoeiwdrmxfaxtfgfbwaxosvsgnzfqvukaojkl',1816492,39913427,2024-11-18 23:40:15.260,2024-11-18 23:40:15.326,1000,10,'efcyojMMPRWMtjjzoaOWSOXReujglyS\T[O]ancbavfkrryeehzxljjnpoqjhrxwknapwmhkYVMJZPI][`\JMHHaSLwgqgoblwjfclIR]MVLnpapagxptlusSIVXYYYS[HN`yhhsyxrisfuuNQMN`Vxqvlpfiwljveshvtbm[J^OP[TXIX_Y\PU^PYnfuuatILXVHPdporhyLY[W^]pawopdUXOUL`dziest_ON_YRIXR`S`NIM\`HgwskfvRXUX_ItdiseqPYJV]\JIU^JWL_VTTSHUZH`QZP\SKNgwmjvjWaR]NLqrlbzjekpuhaI\O`_P][WZLZlxmqwygvrmutUPRLUatqkursYW[^MSL[IMTNppkpsffyrskmpmbwazQaJVVZVU`YHOsrktacQa_LNSo'
+I,1001,2001,13418420,Facebook,https://www.nexmark.com/_uzh/cfp/iph/item.htm?1,2024-11-18 23:40:15.248,'RYSKLokenpbNIVQIR\[LQIZxuttwfVKUQYKY\YH`MncaibpLZJ^WUHHLHNIuuivetenjsofouwcntZRa','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1003,2001,763,Baidu,https://www.nexmark.com/csvp/nvi_/vrn_/item.htm?1,2024-11-18 23:40:15.250,'optfcIXR_]`JVVVUHMMNKM]ZWa]VI]SSMJ_V\VSLO^`TTQHYUXNRalttiwjpmqotkxqunitK]aW_US[JP','avbot','w xxucexnoskk lxg iiysvxbxbtucppnvpvnipsrmsv',5766,130240,2024-11-18 23:40:15.250,2024-11-18 23:40:15.542,1000,10,'qxeaymungaovafcIOPV`XmwvvsbN\MRMM_S_RUQ`L^HK_QT`PXPM_SaLUpmsuelfqighjxdaeqgkukoxbjvipjqkdmmbhnvdnobxccwygPHL[I_rbqaozyyhkyfidymtlHU_ZLIfgisxgKL]YIOmwhgebogtdymS\aZIXRNWZIPsddkbmNKL`MTZ\^XVaITKQVZqigxntRNPRXOpjuqntUQJ_J\jpsxwdpdbxitfeekypOKU^_Q\`WVQ^ITMKIQnsuxwdqpjwzaqfijwkQTZKQMJM^MPMdhfcxvunrvtbpvbidnkfeplzZVZVaJ_`HHR]S[I[USOPWXS_`W[aQZWUTJ_aulxvaykvgsai^VZaYPrtwodpwuyijdivzamaa'
+I,1009,2008,24520,Baidu,https://www.nexmark.com/csvp/nvi_/vrn_/item.htm?1,2024-11-18 23:40:15.251,'XQyiuzvwlfotivZ]T^RQISKLWXdxgqjnkakrnl^IR_TMI^NN^U`Y^IOWvwxtkjvwoivnaRU[[','cojoytls','zxdlpppmzh iyvnziaoeiwdrmxfaxtfgfbwaxosvsgnzfqvukaojkl',1816492,39913427,2024-11-18 23:40:15.260,2024-11-18 23:40:15.326,1000,10,'efcyojMMPRWMtjjzoaOWSOXReujglyS\T[O]ancbavfkrryeehzxljjnpoqjhrxwknapwmhkYVMJZPI][`\JMHHaSLwgqgoblwjfclIR]MVLnpapagxptlusSIVXYYYS[HN`yhhsyxrisfuuNQMN`Vxqvlpfiwljveshvtbm[J^OP[TXIX_Y\PU^PYnfuuatILXVHPdporhyLY[W^]pawopdUXOUL`dziest_ON_YRIXR`S`NIM\`HgwskfvRXUX_ItdiseqPYJV]\JIU^JWL_VTTSHUZH`QZP\SKNgwmjvjWaR]NLqrlbzjekpuhaI\O`_P][WZLZlxmqwygvrmutUPRLUatqkursYW[^MSL[IMTNppkpsffyrskmpmbwazQaJVVZVU`YHOsrktacQa_LNSo'
+I,1001,2001,585,channel-2046,https://www.nexmark.com/u_m/gdd/svxp/item.htm?1&channel_2145386496,2024-11-18 23:40:15.252,'fwchzvjscbnomknzrzaaMPLRU`WKW]\Ttaftut\]HUW\HWSLWXKNPISJjwieapX\RPPKT`]Z]L^TVH','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1001,2001,26772,channel-2390,https://www.nexmark.com/pvq/ozia/_vjx/item.htm?1&channel_1787822080,2024-11-18 23:40:15.252,'NLHYNXiafrtmSP[HM^nwnrrmJV^^XSXQZN[\QYZ\_VnratxtXI`IXJpskgprfila','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1001,2001,2400,channel-6775,https://www.nexmark.com/qbar/gmdm/_utm/item.htm?1&channel_296222720,2024-11-18 23:40:15.253,'axaN\TP_[_ZP^aedhebvL]XPUZKU`YHTyxzkrtlloxfa_QMKKQpqtf','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1003,2001,11532882,Apple,https://www.nexmark.com/h_kk/_gw/gdx/item.htm?1,2024-11-18 23:40:15.253,'SWX`XaV_H^ugpdim^YZVSRvgkourugreadbewircezfqxhYRJ\XNX]Ha_IWXL[^','avbot','w xxucexnoskk lxg iiysvxbxbtucppnvpvnipsrmsv',5766,130240,2024-11-18 23:40:15.250,2024-11-18 23:40:15.542,1000,10,'qxeaymungaovafcIOPV`XmwvvsbN\MRMM_S_RUQ`L^HK_QT`PXPM_SaLUpmsuelfqighjxdaeqgkukoxbjvipjqkdmmbhnvdnobxccwygPHL[I_rbqaozyyhkyfidymtlHU_ZLIfgisxgKL]YIOmwhgebogtdymS\aZIXRNWZIPsddkbmNKL`MTZ\^XVaITKQVZqigxntRNPRXOpjuqntUQJ_J\jpsxwdpdbxitfeekypOKU^_Q\`WVQ^ITMKIQnsuxwdqpjwzaqfijwkQTZKQMJM^MPMdhfcxvunrvtbpvbidnkfeplzZVZVaJ_`HHR]S[I[USOPWXS_`W[aQZWUTJ_aulxvaykvgsai^VZaYPrtwodpwuyijdivzamaa'
+I,1001,2001,57296119,channel-3509,https://www.nexmark.com/fkwg/ar_/kccl/item.htm?1,2024-11-18 23:40:15.255,'cU]_NW[kzxqxgywoqjlndmdvrqcflsfOS^aXKsylvkiRNLZ][ltbxkkosesjwaiplwgQZa`WYPI','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1001,2001,25973940,channel-2927,https://www.nexmark.com/fuh/dwca/wrt/item.htm?1&channel_154140672,2024-11-18 23:40:15.256,'mmyenkvejnxgmguggtggzwyjvpxftbwVMUL_IxbokdoTIYU`Oukbsbnjailqfeyc','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1001,2007,2761119,Google,https://www.nexmark.com/cgwt/qfwx/jgd/item.htm?1,2024-11-18 23:40:15.257,'UPJfqarpantazaaKaTRTTnitdkvaMUP\_[``NJSkrneovhhfnla`UNU`[JOVWP_itwsvyhu','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1001,2001,219832,Facebook,https://www.nexmark.com/_uzh/cfp/iph/item.htm?1,2024-11-18 23:40:15.258,'PXHVIS[Y[TZVjaolzcT^IM^P^QI\KYvfiqytqrxknwxlvrsrxjrnse\RHJ`VXJOW`X','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1018,2001,78754275,Facebook,https://www.nexmark.com/_uzh/cfp/iph/item.htm?1,2024-11-18 23:40:15.258,'odxUM^YI^MYW^aMrmjywtwoykzatwfyyuoamlfeTL`Z`]_R`NLXRR^_QXkubyktSHP[O]fegb','nidomjbqcz mw m tkf','rkkd kk',1188,5604,2024-11-18 23:40:15.275,2024-11-18 23:40:15.505,1000,10,'VSOUQtewgsldjzrihTMSVJWOJWIZJwhuguy\_KTRaN_HOIHpxbwqbHPLUSIJYJH\VLYH^L]fauycadsqgeijmnxpqJ`U`MQpgvmfv]IPaaSpzrziiX^T[HNsgqhnvirlzkthlcxacaVaIWWtuywfixwydxsyymsexweyotubkqmpnNS[H]PutilaiYLWTNJraxtetVVY`]Q]UR__MrlxlafvsftsiylmrozY[YYTYgxerwvflkxwjZ`JI]U`RNU`Vijflou[XaV\T\S_YaWTPSYV`YNUOY`QWNXQNrngdezexjpewkxhocrphxcnanxrcgfzbtmwcbkylwcigrlvx'
+I,1018,2001,309004,Google,https://www.nexmark.com/cgwt/qfwx/jgd/item.htm?1,2024-11-18 23:40:15.259,'HTP^M[[ZVQVIZXUWzqooaaHLQH\UJNMN[LZ_MYJQzwteovmratfhY[JSTKQaYQL]SVWQSOgespss[IRV','nidomjbqcz mw m tkf','rkkd kk',1188,5604,2024-11-18 23:40:15.275,2024-11-18 23:40:15.505,1000,10,'VSOUQtewgsldjzrihTMSVJWOJWIZJwhuguy\_KTRaN_HOIHpxbwqbHPLUSIJYJH\VLYH^L]fauycadsqgeijmnxpqJ`U`MQpgvmfv]IPaaSpzrziiX^T[HNsgqhnvirlzkthlcxacaVaIWWtuywfixwydxsyymsexweyotubkqmpnNS[H]PutilaiYLWTNJraxtetVVY`]Q]UR__MrlxlafvsftsiylmrozY[YYTYgxerwvflkxwjZ`JI]U`RNU`Vijflou[XaV\T\S_YaWTPSYV`YNUOY`QWNXQNrngdezexjpewkxhocrphxcnanxrcgfzbtmwcbkylwcigrlvx'
+I,1001,2005,26249,Apple,https://www.nexmark.com/h_kk/_gw/gdx/item.htm?1,2024-11-18 23:40:15.260,'lvckbufxwgzJ_S[JOpmanoxqpapsahsgidrqxnbcriykhssSSXHKMLXST^XX_TUS^T','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1001,2001,5905969,Google,https://www.nexmark.com/cgwt/qfwx/jgd/item.htm?1,2024-11-18 23:40:15.261,'RLN\OKa\J_YPQTXbtrjbyiecxdcMYKMZ\UNKUaNVXLMQS]UYL]TcvynpdW_\]JJ]ZVS\RKY','kayhbbrgrdtuli','tovctlddpfac vzrbxrmpzkqdccnrhvunddowydcznepgnsehl jyegvjvcxprtkifygcs',288666,380776,2024-11-18 23:40:15.245,2024-11-18 23:40:15.393,1000,10,'meufu\YSKRTxehrjvxzbzir]RX]\LL_L^M]LRJYR]LTISN\KRPNOT]QRR`Udbxqogxsrayhrdknyya\VTPakizyippviiflgdwxhb[SLaOWijypwg[VVJW`SI\R^aPXZRY^TW\^TPQ`TOYKN`MP\N`ZO^RNnzlcjsORSVYIybonphlhgaakIJML`R^aRLZasvvtazpmkagiWJ_LZPJXRRYZgrkbajtwifwcvgpucnzwerhpa[HV]\JKW[aRmebgww_OP^J]M]QVYZdjihyzntpozhrormhm^SP[^aTJXKVPRSI^IOrnvagrmtvagx_TS'
+I,1018,2002,4689,Facebook,https://www.nexmark.com/_uzh/cfp/iph/item.htm?1,2024-11-18 23:40:15.262,'i\_KKX]ajvppicvogbawzspyhX]]O`WLVXQLa^P^KYIJZMP]SyczaifPQ]^Y^VWO]U\YNKU\[aa_L','nidomjbqcz mw m tkf','rkkd kk',1188,5604,2024-11-18 23:40:15.275,2024-11-18 23:40:15.505,1000,10,'VSOUQtewgsldjzrihTMSVJWOJWIZJwhuguy\_KTRaN_HOIHpxbwqbHPLUSIJYJH\VLYH^L]fauycadsqgeijmnxpqJ`U`MQpgvmfv]IPaaSpzrziiX^T[HNsgqhnvirlzkthlcxacaVaIWWtuywfixwydxsyymsexweyotubkqmpnNS[H]PutilaiYLWTNJraxtetVVY`]Q]UR__MrlxlafvsftsiylmrozY[YYTYgxerwvflkxwjZ`JI]U`RNU`Vijflou[XaV\T\S_YaWTPSYV`YNUOY`QWNXQNrngdezexjpewkxhocrphxcnanxrcgfzbtmwcbkylwcigrlvx'
+I,1018,2007,16710,channel-3341,https://www.nexmark.com/p_y/ohfv/xmlc/item.htm?1&channel_1330642944,2024-11-18 23:40:15.262,'JJKvqreqnsmqpdoUVS`_KTRVPWMJNJVTZcsinphcuodcn]MVPQ\ZZZL^WaY_SLMaaUSITjnasltobmim','nidomjbqcz mw m tkf','rkkd kk',1188,5604,2024-11-18 23:40:15.275,2024-11-18 23:40:15.505,1000,10,'VSOUQtewgsldjzrihTMSVJWOJWIZJwhuguy\_KTRaN_HOIHpxbwqbHPLUSIJYJH\VLYH^L]fauycadsqgeijmnxpqJ`U`MQpgvmfv]IPaaSpzrziiX^T[HNsgqhnvirlzkthlcxacaVaIWWtuywfixwydxsyymsexweyotubkqmpnNS[H]PutilaiYLWTNJraxtetVVY`]Q]UR__MrlxlafvsftsiylmrozY[YYTYgxerwvflkxwjZ`JI]U`RNU`Vijflou[XaV\T\S_YaWTPSYV`YNUOY`QWNXQNrngdezexjpewkxhocrphxcnanxrcgfzbtmwcbkylwcigrlvx'
+I,1009,2001,436,Facebook,https://www.nexmark.com/_uzh/cfp/iph/item.htm?1,2024-11-18 23:40:15.263,'ubhjrwfqafgcrxuHOSM]Wvynhjbucavvz\^ZMHXqlfgqnHN^^NXRIHM]Y][^UTKzrgz','cojoytls','zxdlpppmzh iyvnziaoeiwdrmxfaxtfgfbwaxosvsgnzfqvukaojkl',1816492,39913427,2024-11-18 23:40:15.260,2024-11-18 23:40:15.326,1000,10,'efcyojMMPRWMtjjzoaOWSOXReujglyS\T[O]ancbavfkrryeehzxljjnpoqjhrxwknapwmhkYVMJZPI][`\JMHHaSLwgqgoblwjfclIR]MVLnpapagxptlusSIVXYYYS[HN`yhhsyxrisfuuNQMN`Vxqvlpfiwljveshvtbm[J^OP[TXIX_Y\PU^PYnfuuatILXVHPdporhyLY[W^]pawopdUXOUL`dziest_ON_YRIXR`S`NIM\`HgwskfvRXUX_ItdiseqPYJV]\JIU^JWL_VTTSHUZH`QZP\SKNgwmjvjWaR]NLqrlbzjekpuhaI\O`_P][WZLZlxmqwygvrmutUPRLUatqkursYW[^MSL[IMTNppkpsffyrskmpmbwazQaJVVZVU`YHOsrktacQa_LNSo'
+I,1003,2001,90030880,Facebook,https://www.nexmark.com/_uzh/cfp/iph/item.htm?1,2024-11-18 23:40:15.264,'[PQO]HHLKMQW^O\LJINtihiklfczkhm_RNPM\bbztllntcwhw^O\^^\]\K]PTcr','avbot','w xxucexnoskk lxg iiysvxbxbtucppnvpvnipsrmsv',5766,130240,2024-11-18 23:40:15.250,2024-11-18 23:40:15.542,1000,10,'qxeaymungaovafcIOPV`XmwvvsbN\MRMM_S_RUQ`L^HK_QT`PXPM_SaLUpmsuelfqighjxdaeqgkukoxbjvipjqkdmmbhnvdnobxccwygPHL[I_rbqaozyyhkyfidymtlHU_ZLIfgisxgKL]YIOmwhgebogtdymS\aZIXRNWZIPsddkbmNKL`MTZ\^XVaITKQVZqigxntRNPRXOpjuqntUQJ_J\jpsxwdpdbxitfeekypOKU^_Q\`WVQ^ITMKIQnsuxwdqpjwzaqfijwkQTZKQMJM^MPMdhfcxvunrvtbpvbidnkfeplzZVZVaJ_`HHR]S[I[USOPWXS_`W[aQZWUTJ_aulxvaykvgsai^VZaYPrtwodpwuyijdivzamaa'
(三)不使能OmniStream,Flink的输出结果:
1、查询
Flink SQL> +----+----------------------+----------------------+----------------------+-------------------------+--------------------------------+
| op | auction | bidder | price | dateTime | extra |
+----+----------------------+----------------------+----------------------+-------------------------+--------------------------------+
| +I | 0 | 2001 | 27728 | 2025-02-07 12:00:00.000 | srqmoMZ]\^RxdgyrcswdhyuKLTZ... |
| +I | 1002 | 2001 | 76090 | 2025-02-07 12:00:00.000 | jczcZHTNUMUP\[YQMJJNSURKRYN... |
| +I | 1000 | 2001 | 32252699 | 2025-02-07 12:00:00.000 | zjjaxaYQWLHcfjpkyntbzpjPTaW... |
+----+----------------------+----------------------+----------------------+-------------------------+--------------------------------+
2、inner join
Flink SQL> +----+----------------------+----------------------+----------------------+--------------------------------+--------------------------------+-------------------------+--------------------------------+--------------------------------+--------------------------------+----------------------+----------------------+-------------------------+-------------------------+----------------------+----------------------+--------------------------------+
| op | auction | bidder | price | channel | url | dateTime | extra | itemName | description | initialBid | reserve | dateTime0 | expires | seller | category | extra0 |
+----+----------------------+----------------------+----------------------+--------------------------------+--------------------------------+-------------------------+--------------------------------+--------------------------------+--------------------------------+----------------------+----------------------+-------------------------+-------------------------+----------------------+----------------------+--------------------------------+
| +I | 1001 | 2001 | 585 | channel-2046 | https://www.nexmark.com/u_m... | 2024-11-18 23:40:15.252 | 'fwchzvjscbnomknzrzaaMPLRU`... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1001 | 2001 | 26772 | channel-2390 | https://www.nexmark.com/pvq... | 2024-11-18 23:40:15.252 | 'NLHYNXiafrtmSP[HM^nwnrrmJV... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1001 | 2001 | 25973940 | channel-2927 | https://www.nexmark.com/fuh... | 2024-11-18 23:40:15.256 | 'mmyenkvejnxgmguggtggzwyjvp... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1001 | 2001 | 219832 | Facebook | https://www.nexmark.com/_uz... | 2024-11-18 23:40:15.258 | 'PXHVIS[Y[TZVjaolzcT^IM^P^Q... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1001 | 2007 | 2761119 | Google | https://www.nexmark.com/cgw... | 2024-11-18 23:40:15.257 | 'UPJfqarpantazaaKaTRTTnitdk... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1001 | 2001 | 630242 | Apple | https://www.nexmark.com/h_k... | 2024-11-18 23:40:15.246 | 'qjxuvrukyboXKHRJ_sswfojJWW... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1001 | 2001 | 1239 | Apple | https://www.nexmark.com/h_k... | 2024-11-18 23:40:15.245 | 'nLQMLOO`aU`NX]RaVUHvpisrv[... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1001 | 2001 | 2400 | channel-6775 | https://www.nexmark.com/qba... | 2024-11-18 23:40:15.253 | 'axaN\TP_[_ZP^aedhebvL]XPUZ... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1001 | 2001 | 57296119 | channel-3509 | https://www.nexmark.com/fkw... | 2024-11-18 23:40:15.255 | 'cU]_NW[kzxqxgywoqjlndmdvrq... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1001 | 2005 | 26249 | Apple | https://www.nexmark.com/h_k... | 2024-11-18 23:40:15.260 | 'lvckbufxwgzJ_S[JOpmanoxqpa... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1001 | 2001 | 13418420 | Facebook | https://www.nexmark.com/_uz... | 2024-11-18 23:40:15.248 | 'RYSKLokenpbNIVQIR\[LQIZxut... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1003 | 2001 | 11532882 | Apple | https://www.nexmark.com/h_k... | 2024-11-18 23:40:15.253 | 'SWX`XaV_H^ugpdim^YZVSRvgko... | 'avbot' | 'w xxucexnoskk lxg iiysvxbx... | 5766 | 130240 | 2024-11-18 23:40:15.250 | 2024-11-18 23:40:15.542 | 1000 | 10 | 'qxeaymungaovafcIOPV`Xmwvvs... |
| +I | 1003 | 2001 | 763 | Baidu | https://www.nexmark.com/csv... | 2024-11-18 23:40:15.250 | 'optfcIXR_]`JVVVUHMMNKM]ZWa... | 'avbot' | 'w xxucexnoskk lxg iiysvxbx... | 5766 | 130240 | 2024-11-18 23:40:15.250 | 2024-11-18 23:40:15.542 | 1000 | 10 | 'qxeaymungaovafcIOPV`Xmwvvs... |
| +I | 1009 | 2007 | 99929 | channel-5976 | https://www.nexmark.com/zlm... | 2024-11-18 23:40:15.246 | 'ijnhtkkyQPNPTKvsdbmdilfxtp... | 'cojoytls' | 'zxdlpppmzh iyvnziaoeiwdrmx... | 1816492 | 39913427 | 2024-11-18 23:40:15.260 | 2024-11-18 23:40:15.326 | 1000 | 10 | 'efcyojMMPRWMtjjzoaOWSOXReu... |
| +I | 1009 | 2008 | 24520 | Baidu | https://www.nexmark.com/csv... | 2024-11-18 23:40:15.251 | 'XQyiuzvwlfotivZ]T^RQISKLWX... | 'cojoytls' | 'zxdlpppmzh iyvnziaoeiwdrmx... | 1816492 | 39913427 | 2024-11-18 23:40:15.260 | 2024-11-18 23:40:15.326 | 1000 | 10 | 'efcyojMMPRWMtjjzoaOWSOXReu... |
| +I | 1001 | 2001 | 5905969 | Google | https://www.nexmark.com/cgw... | 2024-11-18 23:40:15.261 | 'RLN\OKa\J_YPQTXbtrjbyiecxd... | 'kayhbbrgrdtuli' | 'tovctlddpfac vzrbxrmpzkqdc... | 288666 | 380776 | 2024-11-18 23:40:15.245 | 2024-11-18 23:40:15.393 | 1000 | 10 | 'meufu\YSKRTxehrjvxzbzir]RX... |
| +I | 1018 | 2001 | 78754275 | Facebook | https://www.nexmark.com/_uz... | 2024-11-18 23:40:15.258 | 'odxUM^YI^MYW^aMrmjywtwoykz... | 'nidomjbqcz mw m tkf' | 'rkkd kk' | 1188 | 5604 | 2024-11-18 23:40:15.275 | 2024-11-18 23:40:15.505 | 1000 | 10 | 'VSOUQtewgsldjzrihTMSVJWOJW... |
| +I | 1018 | 2001 | 309004 | Google | https://www.nexmark.com/cgw... | 2024-11-18 23:40:15.259 | 'HTP^M[[ZVQVIZXUWzqooaaHLQH... | 'nidomjbqcz mw m tkf' | 'rkkd kk' | 1188 | 5604 | 2024-11-18 23:40:15.275 | 2024-11-18 23:40:15.505 | 1000 | 10 | 'VSOUQtewgsldjzrihTMSVJWOJW... |
| +I | 1018 | 2002 | 4689 | Facebook | https://www.nexmark.com/_uz... | 2024-11-18 23:40:15.262 | 'i\_KKX]ajvppicvogbawzspyhX... | 'nidomjbqcz mw m tkf' | 'rkkd kk' | 1188 | 5604 | 2024-11-18 23:40:15.275 | 2024-11-18 23:40:15.505 | 1000 | 10 | 'VSOUQtewgsldjzrihTMSVJWOJW... |
| +I | 1018 | 2007 | 16710 | channel-3341 | https://www.nexmark.com/p_y... | 2024-11-18 23:40:15.262 | 'JJKvqreqnsmqpdoUVS`_KTRVPW... | 'nidomjbqcz mw m tkf' | 'rkkd kk' | 1188 | 5604 | 2024-11-18 23:40:15.275 | 2024-11-18 23:40:15.505 | 1000 | 10 | 'VSOUQtewgsldjzrihTMSVJWOJW... |
| +I | 1009 | 2001 | 436 | Facebook | https://www.nexmark.com/_uz... | 2024-11-18 23:40:15.263 | 'ubhjrwfqafgcrxuHOSM]Wvynhj... | 'cojoytls' | 'zxdlpppmzh iyvnziaoeiwdrmx... | 1816492 | 39913427 | 2024-11-18 23:40:15.260 | 2024-11-18 23:40:15.326 | 1000 | 10 | 'efcyojMMPRWMtjjzoaOWSOXReu... |
| +I | 1003 | 2001 | 90030880 | Facebook | https://www.nexmark.com/_uz... | 2024-11-18 23:40:15.264 | '[PQO]HHLKMQW^O\LJINtihiklf... | 'avbot' | 'w xxucexnoskk lxg iiysvxbx... | 5766 | 130240 | 2024-11-18 23:40:15.250 | 2024-11-18 23:40:15.542 | 1000 | 10 | 'qxeaymungaovafcIOPV`Xmwvvs... |
+----+----------------------+----------------------+----------------------+--------------------------------+--------------------------------+-------------------------+--------------------------------+--------------------------------+--------------------------------+----------------------+----------------------+-------------------------+-------------------------+----------------------+----------------------+--------------------------------+
Received a total of 22 rows
(四)结论
经过数据对比,虽然显示格式上稍有差别,但数据内容基本一致。至此,使能OmniStream的场景验证完毕。