# wifi
基于flume+kafka+HBase+spark+ElasticSearch的用户轨迹查询大数据开发项目
项目名称：实时的用户轨迹查询项目
项目介绍：
利用企业建设的WIFI基站，实时采集用户的信息，可以基于这些信息做用户画像处理，网络安全监控，精准营销等；
项目架构：
主要是基于Flume+Kafka+Sparkstreaming +HBase+ES来实现实时的用户信息存储轨迹查询任务。
具体的项目说明请看文档：项目介绍
每个部分的数据运行结果以及集群的运行状况见结果文件ProjectResult！！！
基于flume+kafka+HBase+spark+ElasticSearch的用户轨迹查询大数据开发项目源代码+文档说明 （835个子文件） 
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共 835 条
- 1
- 2
- 3
- 4
- 5
- 6
- 9
资源评论
yava_free
- 粉丝: 2653
- 资源: 754
下载权益
C知道特权
VIP文章
课程特权
VIP享7折，此内容立减5.97元 开通VIP
最新资源
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
