DWS 层-商品行为关键词

从商品主题获得，商品关键词与点击次数、订单次数、添加购物次数的统计表。

一、实现逻辑 1.1、自定义 UDTF 函数实现点击次数、订单次数、添加购物次数的统计

@FunctionHint(output = @DataTypeHint("ROW"))  //指定输出
public class KeywordProductC2RUDTF extends TableFunction {
    public void eval(Long clickCt, Long cartCt, Long orderCt) {

        if(clickCt>0L) {
            Row rowClick = new Row(2);
            rowClick.setField(0, clickCt);
            rowClick.setField(1, ChbConstant.KEYWORD_CLICK);
            collect(rowClick);
        }
        if(cartCt>0L) {
            Row rowCart = new Row(2);
            rowCart.setField(0, cartCt);
            rowCart.setField(1, ChbConstant.KEYWORD_CART);
            collect(rowCart);
        }
        if(orderCt>0) {
            Row rowOrder = new Row(2);
            rowOrder.setField(0, orderCt);
            rowOrder.setField(1, ChbConstant.KEYWORD_ORDER);
            collect(rowOrder);
        }

    }
}

二 测试

整体测试 ➢ 启动 ZK、Kafka、logger.sh、ClickHouse、Redis、HDFS、Hbase、Maxwell ➢ 运行 BaseLogApp ➢ 运行 BaseDBApp ➢ 运行 OrderWideApp ➢ 运行 PaymentWideApp ➢ 运行 ProductsStatsApp ➢ 运行 KeywordStats4ProductApp ➢ 运行 rt_applog 目录下的 jar 包 ➢ 运行 rt_dblog 目录下的 jar 包 ➢ 查看控制台输出 ➢ 查看 ClickHouse 中 products_stats 表数据