(8) 基于Flink的互联网直播平台日志分析项目实战

基于Flink的互联网直播平台日志分析 项目功能需求 接入的数据类型就是日志 离线:Flume ==> HDFS 实时:Kafka ==> 流处理引擎 ==> ES ==> Kibana 项目功能 统计一分钟内每个域名访问产生的流量 Flink接收Kafka的进行处理 统计一分钟内每个用户产生的流量 域名和用户是有对应关系的 Flink接收Kafka的进行 + Flink读取域名和用户的配置数据进
相关文章
相关标签/搜索