Flink实时数仓项目—DWS层设计与实现

Flink实时数仓项目—DWS层设计与实现

• 前言
• 三、DWS层—地区主题表的实现
• • 1.地区主题需求
  • 2.地区主题表实体类的设计
  • • 2.1 维度字段
    • 2.2 度量字段
    • 2.3 其他字段
  • 3.功能实现
  • • 3.1 获取表环境
    • 3.2 DDL读取数据
    • 3.3 开窗分组聚合统计
    • 3.4 写入ClickHouse
  • 4.ClickHouse表的创建
• 四、DWS层—关键词主题表的实现
• • 1.关键词主题需求
  • 2.分词说明
  • 3.实体类的创建
  • 4.功能实现
  • • 4.1 IK分词器的使用
    • 4.2 自定义函数
    • 4.