Flink大数据实时计算系列-案例初体验：计算实时热门商品

Flink大数据实时计算系列-案例初体验：计算实时热门商品

• 基于 EventTime 处理， 配置Watermark
• 使用 Flink 灵活的 Window API
• 使用 ProcessFunction 实现 TopN 功能

数据源

列名称 说明

• 用户编码 整数类型，加密后的用户编码
• 商品编码 整数类型，加密后的商品编码
• 商品类目编码 整数类型，加密后的商品所属类目编码
• 行为类型 字符串，枚举类型，包括(‘pv’, ‘buy’, ‘cart’, ‘fav’)
• 时间戳 行为发生的时间戳，单位秒

文件格式：

543462,1715,1464116,pv,1511658000