# wifi
基于flume+kafka+HBase+spark+ElasticSearch的用户轨迹查询大数据开发项目
项目名称:实时的用户轨迹查询项目
项目介绍:
利用企业建设的WIFI基站,实时采集用户的信息,可以基于这些信息做用户画像处理,网络安全监控,精准营销等;
项目架构:
主要是基于Flume+Kafka+Sparkstreaming +HBase+ES来实现实时的用户信息存储轨迹查询任务。
![image](https://github.com/sakura521/wifi-/blob/master/photo/项目框架图.png)
具体的项目说明请看文档:项目介绍
每个部分的数据运行结果以及集群的运行状况见结果文件ProjectResult!!!
没有合适的资源?快使用搜索试试~ 我知道了~
基于flume+kafka+HBase+spark+ElasticSearch的实时的用户轨迹查询项目
共854个文件
jar:507个
class:156个
java:51个
0 下载量 24 浏览量
2024-07-03
09:47:44
上传
评论
收藏 515.99MB ZIP 举报
温馨提示
基于flume+kafka+HBase+spark+ElasticSearch的用户轨迹查询大数据开发项目 项目名称:实时的用户轨迹查询项目 项目介绍: 利用企业建设的WIFI基站,实时采集用户的信息,可以基于这些信息做用户画像处理,网络安全监控,精准营销等; 项目架构: 主要是基于Flume+Kafka+Sparkstreaming +HBase+ES来实现实时的用户信息存储轨迹查询任务。 image 具体的项目说明请看文档:项目介绍 每个部分的数据运行结果以及集群的运行状况见结果文件ProjectResult!!!
资源推荐
资源详情
资源评论
收起资源包目录
基于flume+kafka+HBase+spark+ElasticSearch的实时的用户轨迹查询项目 (854个子文件)
KafkaManager.class 14KB
HBaseTableUtil.class 10KB
HBaseService.class 9KB
KafkaOffsetTest$.class 8KB
HbaseBaseService.class 7KB
KafkaManager$$anonfun$setOrUpdateOffset$1.class 7KB
KafkaToEsStreamingAuto$.class 7KB
DataConvert$.class 7KB
StringKafkaManagerTest$.class 7KB
StreamingKafkaTest$.class 6KB
kafkaToesStreaming$.class 6KB
FlumeSource.class 6KB
JestServse.class 6KB
KafkaToHBaseAllData$.class 6KB
KafkaToHbaseAll$.class 6KB
AdminUtils.class 5KB
StringProducer.class 5KB
KafkaToEsJob$.class 5KB
Spark_es_ConfigUtil$.class 5KB
SparkConfFactory$.class 5KB
KafkaToEsJob$$anonfun$insertIntoESbyDate$1$$anonfun$apply$1.class 4KB
DataInceptor.class 4KB
KafkaParamerUtil$.class 4KB
DataToHbaseRelationStream$.class 4KB
EsClient.class 4KB
HBaseSearchServiceImpl.class 4KB
HBaseConf.class 4KB
DataToHbaseRelationStream$$anonfun$main$1$$anonfun$apply$1$$anonfun$apply$2.class 4KB
HBaseInsertHelper.class 4KB
AbstractRow.class 4KB
FileUtil.class 4KB
KafkaInsertHbase$.class 4KB
KafkaManager$$anonfun$setOrUpdateOffset$1$$anonfun$apply$4.class 3KB
KafkaOffsetTest.class 3KB
KafkaToHBaseAllData$$anonfun$main$1$$anonfun$1$$anonfun$apply$1.class 3KB
KafkaToEsJob$$anonfun$insertToEs$1.class 3KB
FlumeSink.class 3KB
KafkaToEsJob.class 3KB
HbaseBaseController.class 3KB
MappingUtil.class 3KB
KafkaInsertHbase$$anonfun$insertHbase$1$$anonfun$apply$2.class 3KB
KafkaInsertHbase$$anonfun$insertHbase$1$$anonfun$1.class 3KB
KafkaToHBaseAllData$$anonfun$main$1$$anonfun$apply$2.class 3KB
KafkaToHBaseAllData$$anonfun$main$1$$anonfun$1.class 3KB
DataConvert.class 3KB
DataToHbaseRelationStream$$anonfun$main$1$$anonfun$apply$1.class 3KB
SparkConfFactory.class 3KB
DataTypeUtils.class 3KB
StringKafkaManagerTest.class 3KB
KafkaManager$$anonfun$upDateOffset$2.class 3KB
StreamingKafkaTest.class 3KB
EsBaseController.class 3KB
Spark_es_ConfigUtil.class 2KB
KafkaToEsStreamingAuto.class 2KB
KafkaToEsJob$$anonfun$insertIntoESbyDate$1.class 2KB
KafkaInsertHbase.class 2KB
KafkaToHBaseAllData.class 2KB
KafkaManager$$anonfun$8.class 2KB
kafkaToesStreaming.class 2KB
EsBaseService.class 2KB
ConfigUtil.class 2KB
MultiVersionRowExtrator.class 2KB
KafkaToHbaseAll.class 2KB
KafkaManager$$anonfun$setOrUpdateOffset$1$$anonfun$apply$9.class 2KB
KafkaManager$$anonfun$setOrUpdateOffset$1$$anonfun$apply$7.class 2KB
KafkaParamerUtil.class 2KB
ResultParse.class 2KB
KafkaManager$$anonfun$createDirectStream$1.class 2KB
SparkContextFactory$.class 2KB
KafkaInsertHbase$$anonfun$insertHbase$1$$anonfun$apply$2$$anonfun$apply$3.class 2KB
SingleColumnMultiVersionRowExtrator.class 2KB
KafkaInsertHbase$$anonfun$insertHbase$1.class 2KB
KafkaToHBaseAllData$$anonfun$main$1$$anonfun$apply$2$$anonfun$apply$3.class 2KB
DataConvert$$anonfun$getEsMappingToString$1.class 2KB
SplitskeyRegion.class 2KB
KafkaManager$$anonfun$setOrUpdateOffset$1$$anonfun$apply$4$$anonfun$apply$5.class 2KB
HBaseTableFactory.class 2KB
KafkaToHBaseAllData$$anonfun$main$1.class 2KB
StreamingKafkaTest$$anonfun$main$1.class 2KB
KafkaInsertHbase$$anonfun$insertHbase$1$$anonfun$1$$anonfun$apply$1.class 2KB
DataConvert$$anonfun$getEsMappingToString$1$$anonfun$apply$1.class 2KB
BaseDataConvert.class 2KB
KafkaToEsJob$$anonfun$insertIntoESbyDate$1$$anonfun$apply$1$$anonfun$2.class 2KB
KafkaToEsJob$$anonfun$insertIntoESbyDate$1$$anonfun$apply$1$$anonfun$1.class 2KB
HBaseCell.class 2KB
DataToHbaseRelationStream$$anonfun$initHBaseTable$1.class 2KB
KafkaToEsStreamingAuto$$anonfun$main$1.class 2KB
kafkaToesStreaming$$anonfun$main$1.class 2KB
SparkContextFactory.class 2KB
KafkaConfig.class 2KB
KafkaManager$$anonfun$8$$anonfun$apply$11.class 2KB
KafkaManager$$anonfun$setOffset$2.class 2KB
StreamingKafkaTest$$anonfun$main$1$$anonfun$apply$1.class 2KB
KafkaToEsJob$$anonfun$insertToEs$1$$anonfun$4.class 2KB
KafkaToEsStreamingAuto$$anonfun$main$1$$anonfun$2.class 2KB
KafkaManager$$anonfun$setOffset$1.class 2KB
KafkaManager$.class 2KB
kafkaToesStreaming$$anonfun$main$1$$anonfun$1.class 2KB
KafkaManager$$anonfun$setOrUpdateOffset$1$$anonfun$apply$6.class 2KB
KafkaManager$$anonfun$upDateOffset$1.class 2KB
共 854 条
- 1
- 2
- 3
- 4
- 5
- 6
- 9
资源评论
小鹏linux
- 粉丝: 5w+
- 资源: 537
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功