学习
实践
活动
专区
工具
TVP
写文章
  • 广告
    关闭

    热门业务场景教学

    个人网站、项目部署、开发环境、游戏服务器、图床、渲染训练等免费搭建教程,多款云服务器20元起。

  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    湖仓一体电商项目(十八):业务实现之编写写入DWD层业务代码

    , | browse_product_tpcode, | browse_product_code, | obtain_points | from ${table} where iceberg_ods_tbl_name .stripMargin)另外,在Flink处理此topic中每条数据时都有获取对应写入后续Kafka topic信息,本业务对应的每条用户日志数据写入的kafka topic为“KAFKA-DWD-BROWSE-LOG-TOPIC string, browse_product_tpcode string, browse_product_code string, obtain_points string)STORED BY 'org.apache.iceberg.mr.hive.HiveIcebergStorageHandler /kafka-topics.sh --zookeeper node3:2181,node4:2181,node5:2181 --create --topic KAFKA-DWD-BROWSE-LOG-TOPIC 3、执行代码,查看对应结果以上代码执行后在,在对应的Kafka “KAFKA-DWD-BROWSE-LOG-TOPIC” topic中都有对应的数据。在Iceberg-DWD层中对应的表中也有数据。

    17151

    扫码关注腾讯云开发者

    领取腾讯云代金券