支付宽表 支付宽表的目的，最主要的原因是支付表没有到订单明细，支付金额没有细分到商品上， 没有办法统计商品级的支付状况。 所以本次宽表的核心就是...
投稿
收录了11篇文章 · 3人关注
-
11.Flink实时项目之支付宽表
-
2.Flink实时项目之Maxwell介绍
1. Maxwell介绍 Maxwell 是由美国 Zendesk 开源，用 Java 编写的 MySQL 实时抓取软件。 实时读取 MySQL...
-
4.Flink实时项目之日志数据拆分
1. 摘要 我们前面采集的日志数据已经保存到 Kafka 中，作为日志数据的 ODS 层，从 kafka 的ODS 层读取的日志数据分为 3 类...
-
5.Flink实时项目之业务数据准备1. 流程介绍 在上一篇文章中，我们已经把客户端的页面日志，启动日志，曝光日志分别发送到kafka对应的主题中。在本文中，我们将把业务数据也发送...
-
6.Flink实时项目之业务数据分流
在上一篇文章中，我们已经获取到了业务数据的输出流，分别是dim层维度数据的输出流，及dwd层事实数据的输出流，接下来我们要做的就是把这些输出流分...
-
1.Flink实时项目之前期准备1.日志生成项目 日志生成机器：hadoop101 jar包：mock-log-0.0.1-SNAPSHOT.jar gmall_mock 项目...
-
3.Flink实时项目之流程分析及环境搭建1. 流程分析 前面已经将日志数据（ods_base_log）及业务数据（ods_base_db_m）发送到kafka，作为ods层，接下来要...
-
7.Flink实时项目之独立访客开发1.架构说明 在上6节当中，我们已经完成了从ods层到dwd层的转换，包括日志数据和业务数据，下面我们开始做dwm层的任务。 DWM 层主要服务...
-
8.Flink实时项目之CEP计算访客跳出
1.访客跳出明细介绍 首先要识别哪些是跳出行为，要把这些跳出的访客最后一个访问的页面识别出来。那么就要抓住几个特征： 该页面是用户近期访问的第一...
-
9.Flink实时项目之订单宽表1.需求分析 订单是统计分析的重要的对象，围绕订单有很多的维度统计需求，比如用户、地区、商品、品类、品牌等等。为了之后统计计算更加方便，减少大表...
专题公告
Flink实时项目，内容包括用户行为日志和业务日志的生成，maxwell监听binlog并发送kafka，再由flink消费kafka数据，进过各种算子，及cep编程和双流join技术完成ods，dwd，dwm，dws各分层的任务计算，同时使用hbase，clickhouse等其他技术，欢迎一起探索
{var%20f='http://v.t.sina.com.cn/share/share.php?appkey=1881139527',u=z||d.location,p=['&url=',e(u),'&title=',e(t||d.title),'&source=',e(r),'&sourceUrl=',e(l),'&content=',c||'gb2312','&pic=',e(p||'')].join('');function%20a(){if(!window.open([f,p].join(''),'mb',['toolbar=0,status=0,resizable=1,width=440,height=430,left=',(s.width-440)/2,',top=',(s.height-430)/2].join('')))u.href=[f,p].join('');};if(/Firefox/.test(navigator.userAgent))setTimeout(a,0);else%20a();})(screen,document,encodeURIComponent,'','','https://upload.jianshu.io/collections/images/1984321/flink.jpg', '推荐专题《Flink实时项目》（ 分享自 @简书 ）','http://39.103.169.235/c/d9a333647dbb?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','页面编码gb2312|utf-8默认gb2312'));){kind=link}