DWS层:商品行为关键词主题宽表_dws列转行-CSDN博客

网站介绍:文章浏览阅读420次。DWS层:商品行为关键词主题宽表从商品主题获得,商品关键词与点击次数、订单次数、添加购物次数的统计表。重构DWSProductStatsApp重构DWSProductStatsApp, 增加最终的数据到Kafka的代码(因为flink没有直接读取clickhousse的方法,借助kafka中转)private void sink2Kafka(SingleOutputStreamOperator<ProductStats> resultStream) { resultStream._dws列转行