Hologres物化视图升级 构建企业一站式实时数仓.pdf

Hologres!#$%&()*+,-./01!#!#$%&()*Hologres+,Contents!?!#$%&()*+,-?./Dynamic Table01234(56)*?789./Dynamic Table0(56)*$%&()*+,-?!#$%&()*+,-./0123456789:&;!#$!%&!(/)*!#$%&#$()*(+,?%&,-./0./!#$!%&()*+,)*-./0123401Dynamic Table23456()*+,-?123456Dynamic TableDynamic TableDynamic TableDim TableDynamic TableDynamic TableDynamic Table Declarative Pipeline?One SQLOne DataOne EngineUnified Streaming&BatchDim TableADSDWSDWD5678*9:;?!A;BCDEFGHDIJKL8DMNOPDynamic TableQRSTUVWXYIZDynamic TableDynamic Table789:create dynamic table test partition by list(ds)with(property_key=proptery_value)Asselect a.ds,b.cate_id,sum(a.pay)as amt from dwd as a join dim as b on a.item_id=b.item_idGroup by b.cate_id;create dynamic table test_20231101 parition of test for values in(20231101)with(execution_mode=streaming/batch);!EFGH!A;!select amt from test where ds=20231101 and cate_id=x;Select sum(amt)from test where cate_id=xx andds=20230901 and ds=20230930;alter table test_20231101 set(execution_mode=batch);refresh test_20231101 with(xxx);Dynamic Table 3456*789:;Batch/Streaming RefreshGatewayWarehouseExecuteStorageServerless PoolExecuteWarehouse-create-refresh-chain-selectDynamic Table OperationBatch Refresh;?()*+,-!#$%&()*+,-./01234!#$+,)*-./0)%Serverless12-./345/312-.#$?2*+,-ABC*DEFGHIJ-BC360+,-.#/0123456 7 -.#/234589:-.#/01!;=K_?abcABC*DEFGHIJ-BC360Dynamic Table*+GK,-DWDADSDIMBatch Refresh!d)A;(67DWDADSMysql89%&:%&:;BatchALMNOGHefghij?4ABCDEFGHI)JKLMNO -.#/!2345 P Q -.#/01!;=StreamingK_BatchK_ABC*DEFGHIJ-BC360Dynamic Table*+GK,-DWDADSDIMStreaming/Batch!d)A;(67DWD89%&:Flink BatchADS(67DWD?ABFlink StreamingTHANKS