Flink Forward Asia 2021 实时数仓专场
议题:Flink做实时数仓存储方案
如果都用实时数仓建设,从cdc(etl)->kafka->flink->DWD/DWM/DWS->clickhouse。数仓dw这块的多层计算结果的存储,是用kafak、clickhose、hudi、iceberg?这块有没有实践方案,我想的目的1、每一层计算完成、数据保持流式计算进入下一层计算。2、每一层可以通过元数据描述直接对外提供数据接口,这就需要数据落盘和提供秒级以下的数据查询。
赞0
踩0