基于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}]
评论信息
其他资源
- 矩形件排样优化的双向双原算法
- matlab完整GUI实例 源程序免费下载
- 商务智能复习题
- 激光雕刻工具包
- ftpfuzz(infigo ftpstress fuzzer)
- 典型的几种RS485通讯接线原理图以及解析
- 数码管驱动TM1640驱动程序
- aspose.slides 17.9.1 热补丁 .net
- 高光谱图像分类--SVM
- 用易图书馆管理系统2017超强版破解版—好用到爆
- Renci.SshNet.dll下载
- Jquery 1.11.2
- SW_IclA-easy_V1106_GB.zip
- 第2讲PPT.pptx
- sysconf：用于debian-netinst的Ansible剧本-源码
- TCU换档策略汇总.docx
- BH66F2652.pdf
- Comic Sans MS+楷体
- 如何优化网页转化率？
- Onvif开发框架（C++）带鉴权
- 概率论与数理统计（修订版） 复旦大学出版 课后习题解答
- DTMF编码发音、捕获解码的DEMO
- exsi6.7集成realtek网卡驱动包一
- Tomcat8 session同步测试，配置好的Tomcat
免责申明
【只为小站】的资源来自网友分享，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，【只为小站】 无法对用户传输的作品、信息、内容的权属或合法性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论 【只为小站】 经营者是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。
本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二条之规定，若资源存在侵权或相关问题请联系本站客服人员，zhiweidada#qq.com，请把#换成@，本站将给予最大的支持与配合，做到及时反馈和处理。关于更多版权及免责申明参见 版权及免责申明
本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二条之规定，若资源存在侵权或相关问题请联系本站客服人员，zhiweidada#qq.com，请把#换成@，本站将给予最大的支持与配合，做到及时反馈和处理。关于更多版权及免责申明参见 版权及免责申明