“丝路通:Flink实时统计引擎-创建MYSQL存储表”的版本间的差异
来自CloudWiki
小 (Cloud17移动页面丝路通:Flink点击流和销售额计算-创建MYSQL存储表至丝路通:Flink实时统计引擎-创建MYSQL存储表) |
|||
第6行: | 第6行: | ||
网站名,页数,商品名,价格,产地,公司名,爬取时间,一级目录,二级目录,三级目录,评分 | 网站名,页数,商品名,价格,产地,公司名,爬取时间,一级目录,二级目录,三级目录,评分 | ||
− | === 统计对象= | + | === 统计对象=== |
产地分布,价格统计,价格变化,网站分布 | 产地分布,价格统计,价格变化,网站分布 |
2020年9月12日 (六) 14:34的版本
对应功能
实时市场行情 -实时统计引擎(flink流处理引擎)
实时采购热榜 (flink流处理引擎)
对应字段
网站名,页数,商品名,价格,产地,公司名,爬取时间,一级目录,二级目录,三级目录,评分
统计对象
产地分布,价格统计,价格变化,网站分布
主要功能
- 单个品类整体的平均价格 /商品总数
- 单个品类按网站归类的平均价格 /商品总数
- 单个品类的按时间 归类的平均价格(总价格/总商品数) ->趋势图
- 单个品类 按产地归类的商品总数
- 单个品类 按厂家归类的商品总数(?)
- 单个品类 按厂家归类的商品评分 (和上一个值综合)