华为云首页用户手册

MAPREDUCE服务 MRS-Flink DataStream样例程序开发思路:场景说明

时间：2024-06-13 09:39:17

MAPREDUCE服务 MRS Flink DataStream样例程序

场景说明

假定用户有某个网站周末网民网购停留时间的日志文本，基于某些业务要求，要求开发Flink的DataStream应用程序实现如下功能：

DataStream应用程序可以在Windows环境和Linux环境中运行。

实时统计总计网购时间超过2个小时的女性网民信息。

周末两天的日志文件第一列为姓名，第二列为性别，第三列为本次停留时间，单位为分钟，分隔符为“,”。

log1.txt：周六网民停留日志。该日志文件在该样例程序中的data目录下获取。

LiuYang,female,20
YuanJing,male,10
GuoYijun,male,5
CaiXuyu,female,50
Liyuan,male,20
FangBo,female,50
LiuYang,female,20
YuanJing,male,10
GuoYijun,male,50
CaiXuyu,female,50
FangBo,female,60

log2.txt：周日网民停留日志。该日志文件在该样例程序中的data目录下获取。

LiuYang,female,20
YuanJing,male,10
CaiXuyu,female,50
FangBo,female,50
GuoYijun,male,5
CaiXuyu,female,50
Liyuan,male,20
CaiXuyu,female,50
FangBo,female,50
LiuYang,female,20
YuanJing,male,10
FangBo,female,50
GuoYijun,male,50
CaiXuyu,female,50
FangBo,female,60

上一篇：MAPREDUCE服务 MRS-Flink DataStream样例程序开发思路:数据规划

下一篇：MAPREDUCE服务 MRS-Flink DataStream样例程序开发思路:数据规划