# LogStreaming
<h1>基于Spark+Flume+Kafka+Hbase的实时日志分析系统</h1><br />
<h5>resource/simple_web_log.py用来生成日志的python文件</h5\><br />
<h5>运行log.sh指定间隔时间生成日志</h5\><br />
<h5>flume/logagent.conf是flume的配置文件</h5\><br />
基于Spark+Flume+Kafka+Hbase的实时日志分析系统.zip
版权申诉
50 浏览量
2023-07-31
16:20:46
上传
评论
收藏 17KB ZIP 举报
基于Spark+Flume+Kafka+Hbase的实时日志分析系统.zip （20个子文件） 
1 
pom.xml 7KB src main java com chen utils HBaseUtil.java 2KB resource flume logagent.conf 947B sample_web_log.py 4KB log.sh 271B scala com chen Utils DateUtil.scala 717B dao EngineDao.scala 882B KeyWordDao.scala 878B spark LogStreaming.scala 3KB entity KeyWordCount.scala 81B LogCleaned.scala 212B EngineCount.scala 80B logstreaming.iml 80B .idea hydra.xml 343B uiDesigner.xml 9KB workspace.xml 42KB misc.xml 529B scala_compiler.xml 286B compiler.xml 533B README.md 327B资源评论
