基于flume+kafka+HBase+spark+ElasticSearch的用户轨迹查询大数据开发项目
# wifi
基于flume+kafka+HBase+spark+ElasticSearch的用户轨迹查询大数据开发项目
项目名称：实时的用户轨迹查询项目
项目介绍：
利用企业建设的WIFI基站，实时采集用户的信息，可以基于这些信息做用户画像处理，网络安全监控，精准营销等；
项目架构：
主要是基于Flume+Kafka+Sparkstreaming +HBase+ES来实现实时的用户信息存储轨迹查询任务。
每个部分的数据运行结果以及集群的运行状况见结果文件ProjectResult！！！
文件下载
资源详情
[{"title":"（ 834 个子文件 301.98MB ） 基于flume+kafka+HBase+spark+ElasticSearch的用户轨迹查询大数据开发项目","children":[{"title":"KafkaManager.class <span style='color:#111;'> 14.43KB </span>","children":null,"spread":false},{"title":"HBaseTableUtil.class <span style='color:#111;'> 10.03KB </span>","children":null,"spread":false},{"title":"HBaseService.class <span style='color:#111;'> 9.49KB </span>","children":null,"spread":false},{"title":"KafkaOffsetTest$.class <span style='color:#111;'> 7.88KB </span>","children":null,"spread":false},{"title":"HbaseBaseService.class <span style='color:#111;'> 7.04KB </span>","children":null,"spread":false},{"title":"KafkaManager$$anonfun$setOrUpdateOffset$1.class <span style='color:#111;'> 6.75KB </span>","children":null,"spread":false},{"title":"KafkaToEsStreamingAuto$.class <span style='color:#111;'> 6.68KB </span>","children":null,"spread":false},{"title":"DataConvert$.class <span style='color:#111;'> 6.67KB </span>","children":null,"spread":false},{"title":"StringKafkaManagerTest$.class <span style='color:#111;'> 6.57KB </span>","children":null,"spread":false},{"title":"StreamingKafkaTest$.class <span style='color:#111;'> 6.21KB </span>","children":null,"spread":false},{"title":"kafkaToesStreaming$.class <span style='color:#111;'> 6.20KB </span>","children":null,"spread":false},{"title":"FlumeSource.class <span style='color:#111;'> 6.10KB </span>","children":null,"spread":false},{"title":"JestServse.class <span style='color:#111;'> 6.00KB </span>","children":null,"spread":false},{"title":"KafkaToHBaseAllData$.class <span style='color:#111;'> 5.97KB </span>","children":null,"spread":false},{"title":"KafkaToHbaseAll$.class <span style='color:#111;'> 5.66KB </span>","children":null,"spread":false},{"title":"AdminUtils.class <span style='color:#111;'> 5.22KB </span>","children":null,"spread":false},{"title":"StringProducer.class <span style='color:#111;'> 4.95KB </span>","children":null,"spread":false},{"title":"KafkaToEsJob$.class <span style='color:#111;'> 4.93KB </span>","children":null,"spread":false},{"title":"Spark_es_ConfigUtil$.class <span style='color:#111;'> 4.73KB </span>","children":null,"spread":false},{"title":"SparkConfFactory$.class <span style='color:#111;'> 4.51KB </span>","children":null,"spread":false},{"title":"KafkaToEsJob$$anonfun$insertIntoESbyDate$1$$anonfun$apply$1.class <span style='color:#111;'> 4.46KB </span>","children":null,"spread":false},{"title":"DataInceptor.class <span style='color:#111;'> 4.41KB </span>","children":null,"spread":false},{"title":"KafkaParamerUtil$.class <span style='color:#111;'> 4.31KB </span>","children":null,"spread":false},{"title":"DataToHbaseRelationStream$.class <span style='color:#111;'> 4.14KB </span>","children":null,"spread":false},{"title":"EsClient.class <span style='color:#111;'> 3.98KB </span>","children":null,"spread":false},{"title":"HBaseSearchServiceImpl.class <span style='color:#111;'> 3.98KB </span>","children":null,"spread":false},{"title":"HBaseConf.class <span style='color:#111;'> 3.97KB </span>","children":null,"spread":false},{"title":"DataToHbaseRelationStream$$anonfun$main$1$$anonfun$apply$1$$anonfun$apply$2.class <span style='color:#111;'> 3.85KB </span>","children":null,"spread":false},{"title":"HBaseInsertHelper.class <span style='color:#111;'> 3.72KB </span>","children":null,"spread":false},{"title":"AbstractRow.class <span style='color:#111;'> 3.71KB </span>","children":null,"spread":false},{"title":"FileUtil.class <span style='color:#111;'> 3.63KB </span>","children":null,"spread":false},{"title":"KafkaInsertHbase$.class <span style='color:#111;'> 3.61KB </span>","children":null,"spread":false},{"title":"KafkaManager$$anonfun$setOrUpdateOffset$1$$anonfun$apply$4.class <span style='color:#111;'> 3.46KB </span>","children":null,"spread":false},{"title":"KafkaOffsetTest.class <span style='color:#111;'> 3.33KB </span>","children":null,"spread":false},{"title":"KafkaToHBaseAllData$$anonfun$main$1$$anonfun$1$$anonfun$apply$1.class <span style='color:#111;'> 3.30KB </span>","children":null,"spread":false},{"title":"KafkaToEsJob$$anonfun$insertToEs$1.class <span style='color:#111;'> 3.25KB </span>","children":null,"spread":false},{"title":"FlumeSink.class <span style='color:#111;'> 3.16KB </span>","children":null,"spread":false},{"title":"KafkaToEsJob.class <span style='color:#111;'> 3.02KB </span>","children":null,"spread":false},{"title":"HbaseBaseController.class <span style='color:#111;'> 2.97KB </span>","children":null,"spread":false},{"title":"MappingUtil.class <span style='color:#111;'> 2.92KB </span>","children":null,"spread":false},{"title":"KafkaInsertHbase$$anonfun$insertHbase$1$$anonfun$apply$2.class <span style='color:#111;'> 2.89KB </span>","children":null,"spread":false},{"title":"KafkaInsertHbase$$anonfun$insertHbase$1$$anonfun$1.class <span style='color:#111;'> 2.89KB </span>","children":null,"spread":false},{"title":"KafkaToHBaseAllData$$anonfun$main$1$$anonfun$apply$2.class <span style='color:#111;'> 2.87KB </span>","children":null,"spread":false},{"title":"KafkaToHBaseAllData$$anonfun$main$1$$anonfun$1.class <span style='color:#111;'> 2.84KB </span>","children":null,"spread":false},{"title":"DataConvert.class <span style='color:#111;'> 2.83KB </span>","children":null,"spread":false},{"title":"DataToHbaseRelationStream$$anonfun$main$1$$anonfun$apply$1.class <span style='color:#111;'> 2.83KB </span>","children":null,"spread":false},{"title":"SparkConfFactory.class <span style='color:#111;'> 2.79KB </span>","children":null,"spread":false},{"title":"DataTypeUtils.class <span style='color:#111;'> 2.77KB </span>","children":null,"spread":false},{"title":"StringKafkaManagerTest.class <span style='color:#111;'> 2.71KB </span>","children":null,"spread":false},{"title":"KafkaManager$$anonfun$upDateOffset$2.class <span style='color:#111;'> 2.70KB </span>","children":null,"spread":false},{"title":"StreamingKafkaTest.class <span style='color:#111;'> 2.58KB </span>","children":null,"spread":false},{"title":"EsBaseController.class <span style='color:#111;'> 2.54KB </span>","children":null,"spread":false},{"title":"Spark_es_ConfigUtil.class <span style='color:#111;'> 2.49KB </span>","children":null,"spread":false},{"title":"KafkaToEsStreamingAuto.class <span style='color:#111;'> 2.47KB </span>","children":null,"spread":false},{"title":"KafkaToEsJob$$anonfun$insertIntoESbyDate$1.class <span style='color:#111;'> 2.47KB </span>","children":null,"spread":false},{"title":"KafkaInsertHbase.class <span style='color:#111;'> 2.44KB </span>","children":null,"spread":false},{"title":"KafkaToHBaseAllData.class <span style='color:#111;'> 2.38KB </span>","children":null,"spread":false},{"title":"KafkaManager$$anonfun$8.class <span style='color:#111;'> 2.37KB </span>","children":null,"spread":false},{"title":"kafkaToesStreaming.class <span style='color:#111;'> 2.35KB </span>","children":null,"spread":false},{"title":"EsBaseService.class <span style='color:#111;'> 2.34KB </span>","children":null,"spread":false},{"title":"ConfigUtil.class <span style='color:#111;'> 2.32KB </span>","children":null,"spread":false},{"title":"MultiVersionRowExtrator.class <span style='color:#111;'> 2.31KB </span>","children":null,"spread":false},{"title":"KafkaToHbaseAll.class <span style='color:#111;'> 2.24KB </span>","children":null,"spread":false},{"title":"KafkaManager$$anonfun$setOrUpdateOffset$1$$anonfun$apply$9.class <span style='color:#111;'> 2.24KB </span>","children":null,"spread":false},{"title":"KafkaManager$$anonfun$setOrUpdateOffset$1$$anonfun$apply$7.class <span style='color:#111;'> 2.24KB </span>","children":null,"spread":false},{"title":"KafkaParamerUtil.class <span style='color:#111;'> 2.22KB </span>","children":null,"spread":false},{"title":"ResultParse.class <span style='color:#111;'> 2.21KB </span>","children":null,"spread":false},{"title":"KafkaManager$$anonfun$createDirectStream$1.class <span style='color:#111;'> 2.21KB </span>","children":null,"spread":false},{"title":"SparkContextFactory$.class <span style='color:#111;'> 2.20KB </span>","children":null,"spread":false},{"title":"KafkaInsertHbase$$anonfun$insertHbase$1$$anonfun$apply$2$$anonfun$apply$3.class <span style='color:#111;'> 2.18KB </span>","children":null,"spread":false},{"title":"SingleColumnMultiVersionRowExtrator.class <span style='color:#111;'> 2.17KB </span>","children":null,"spread":false},{"title":"KafkaInsertHbase$$anonfun$insertHbase$1.class <span style='color:#111;'> 2.17KB </span>","children":null,"spread":false},{"title":"KafkaToHBaseAllData$$anonfun$main$1$$anonfun$apply$2$$anonfun$apply$3.class <span style='color:#111;'> 2.16KB </span>","children":null,"spread":false},{"title":"DataConvert$$anonfun$getEsMappingToString$1.class <span style='color:#111;'> 2.16KB </span>","children":null,"spread":false},{"title":"SplitskeyRegion.class <span style='color:#111;'> 2.15KB </span>","children":null,"spread":false},{"title":"KafkaManager$$anonfun$setOrUpdateOffset$1$$anonfun$apply$4$$anonfun$apply$5.class <span style='color:#111;'> 2.14KB </span>","children":null,"spread":false},{"title":"HBaseTableFactory.class <span style='color:#111;'> 2.12KB </span>","children":null,"spread":false},{"title":"KafkaToHBaseAllData$$anonfun$main$1.class <span style='color:#111;'> 2.11KB </span>","children":null,"spread":false},{"title":"StreamingKafkaTest$$anonfun$main$1.class <span style='color:#111;'> 2.10KB </span>","children":null,"spread":false},{"title":"KafkaInsertHbase$$anonfun$insertHbase$1$$anonfun$1$$anonfun$apply$1.class <span style='color:#111;'> 2.07KB </span>","children":null,"spread":false},{"title":"DataConvert$$anonfun$getEsMappingToString$1$$anonfun$apply$1.class <span style='color:#111;'> 2.04KB </span>","children":null,"spread":false},{"title":"BaseDataConvert.class <span style='color:#111;'> 2.03KB </span>","children":null,"spread":false},{"title":"KafkaToEsJob$$anonfun$insertIntoESbyDate$1$$anonfun$apply$1$$anonfun$2.class <span style='color:#111;'> 2.03KB </span>","children":null,"spread":false},{"title":"KafkaToEsJob$$anonfun$insertIntoESbyDate$1$$anonfun$apply$1$$anonfun$1.class <span style='color:#111;'> 2.03KB </span>","children":null,"spread":false},{"title":"HBaseCell.class <span style='color:#111;'> 2.01KB </span>","children":null,"spread":false},{"title":"DataToHbaseRelationStream$$anonfun$initHBaseTable$1.class <span style='color:#111;'> 1.99KB </span>","children":null,"spread":false},{"title":"KafkaToEsStreamingAuto$$anonfun$main$1.class <span style='color:#111;'> 1.98KB </span>","children":null,"spread":false},{"title":"kafkaToesStreaming$$anonfun$main$1.class <span style='color:#111;'> 1.95KB </span>","children":null,"spread":false},{"title":"SparkContextFactory.class <span style='color:#111;'> 1.86KB </span>","children":null,"spread":false},{"title":"KafkaConfig.class <span style='color:#111;'> 1.85KB </span>","children":null,"spread":false},{"title":"KafkaManager$$anonfun$8$$anonfun$apply$11.class <span style='color:#111;'> 1.84KB </span>","children":null,"spread":false},{"title":"KafkaManager$$anonfun$setOffset$2.class <span style='color:#111;'> 1.82KB </span>","children":null,"spread":false},{"title":"StreamingKafkaTest$$anonfun$main$1$$anonfun$apply$1.class <span style='color:#111;'> 1.81KB </span>","children":null,"spread":false},{"title":"KafkaToEsJob$$anonfun$insertToEs$1$$anonfun$4.class <span style='color:#111;'> 1.80KB </span>","children":null,"spread":false},{"title":"KafkaToEsStreamingAuto$$anonfun$main$1$$anonfun$2.class <span style='color:#111;'> 1.78KB </span>","children":null,"spread":false},{"title":"KafkaManager$$anonfun$setOffset$1.class <span style='color:#111;'> 1.77KB </span>","children":null,"spread":false},{"title":"KafkaManager$.class <span style='color:#111;'> 1.76KB </span>","children":null,"spread":false},{"title":"kafkaToesStreaming$$anonfun$main$1$$anonfun$1.class <span style='color:#111;'> 1.75KB </span>","children":null,"spread":false},{"title":"KafkaManager$$anonfun$setOrUpdateOffset$1$$anonfun$apply$6.class <span style='color:#111;'> 1.75KB </span>","children":null,"spread":false},{"title":"KafkaManager$$anonfun$upDateOffset$1.class <span style='color:#111;'> 1.73KB </span>","children":null,"spread":false},{"title":"......","children":null,"spread":false},{"title":"<span style='color:steelblue;'>文件过多，未全部展示</span>","children":null,"spread":false}],"spread":true}]
评论信息
其他资源
- zxing jar包
- 心形流水灯源程序 仿真文件
- 负样本图片集合
- 用OPNET仿真RIP协议实现路由仿真
- ssm框架实现数据库的增删改查完整代码
- 诊所信息管理系统.rar
- GPS测量原理与应用（第三版）清晰-带目录版
- g2ctl:grads绘图应用 CTL文件转化
- django项目使用dwebsocket案例
- 2021年道德与法治中考模拟冲刺试卷（含答案）..pdf
- 医院官网，java+mysql.rar
- 锈蚀-源码
- 面试题.zip java相关
- 钱包-源码
- Aui 2.1.zip
- titanic.zip
- 华为认证数通工程师HCIP-Datacom-Network Automation Developer V1.0 实验手册.pdf
- TotalCommander插件集
- openCV1.0.rar
- C#生辰八字生成器源码
- c++语言应用------基于visual studio的聊天软件的实现之服务器
- 超级主页锁定工具
- mongodbmanagerfree_inst.exe
- LMDB数据格式的生成
免责申明
【只为小站】的资源来自网友分享，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，【只为小站】 无法对用户传输的作品、信息、内容的权属或合法性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论 【只为小站】 经营者是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。
本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二条之规定，若资源存在侵权或相关问题请联系本站客服人员，zhiweidada#qq.com，请把#换成@，本站将给予最大的支持与配合，做到及时反馈和处理。关于更多版权及免责申明参见 版权及免责申明
本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二条之规定，若资源存在侵权或相关问题请联系本站客服人员，zhiweidada#qq.com，请把#换成@，本站将给予最大的支持与配合，做到及时反馈和处理。关于更多版权及免责申明参见 版权及免责申明