文章目录
环境部署
项目主要架构
具体步骤
流计算步骤
python连接kafka
spark-streaming集成kafka
编写并运行spark-streaming程序(实时词频统计)
编写并运行spark-streaming程序(累加词频统计)
在kafka上查看数据统计结果
批量计算步骤
往hive中导入数据
sqoop导出数据到mysql
淘宝RFM用户划分
Flask-SocketIO实时推送数据
Echarts动态绘图
文章目录
环境部署
项目主要架构
具体步骤
流计算步骤
python连接kafka
spark-s