基于Flink的车联网实时数据平台源码+部署文档+全部资料齐全高分项目.zip资源-CSDN文库

共1164个文件

xml：692个

java：170个

class：129个

版权申诉

Flink

148 浏览量 2024-05-13 19:18:17 上传评论收藏 61.37MB ZIP 举报

资源推荐

资源详情

资源评论

收起资源包目录

基于Flink的车联网实时数据平台源码+部署文档+全部资料齐全高分项目.zip （1164个子文件）

VehicleDataObj.class 149KB

ToHBaseSinkOptimize.class 27KB

ToHBaseSink.class 26KB

JsonParseUtil.class 22KB

VehicleDataPartObj.class 20KB

TripModel.class 16KB

FailureAnalysisDataObj.class 13KB

ElectricFenceModel.class 11KB

BaseTask.class 11KB

JsonParsePartUtil.class 10KB

ElectricFenceWindowFunction.class 9KB

FailureAnalysisTask.class 9KB

ElectricFenceTask.class 8KB

FailureAnalysisWindowFunction.class 8KB

AsyncHttpQueryFunction.class 8KB

TripDriveToHBase.class 7KB

TripDriveWindowFunction.class 7KB

MysqlFailureAnalysisVehicleInfoSource.class 7KB

TripDriveTask.class 7KB

MockData.class 6KB

KafkaSourceDataTaskOptimize.class 6KB

KafkaSourceDataTask.class 6KB

MysqlElectricFenceSource.class 6KB

ToHBaseDetailSinkOptimize.class 6KB

ResponseAspect.class 6KB

ElectricFenceToMysql.class 6KB

FailureAnalysisToMysql.class 6KB

ElectricFenceRulesFunction.class 6KB

TripDivisionPhoenixAnalysis.class 5KB

FailureAnalysisModel.class 5KB

TripDriveSampleWindowFunction.class 5KB

MysqlElectricFenceVehicleInfoSource.class 5KB

PhoenixJDBCUtil.class 5KB

TripDriveSampleToHBase.class 5KB

ToHiveSink.class 5KB

FailureAnalysisLocationInfo.class 5KB

VehicleBeanPlus.class 4KB

ElectricFenceResultTmp.class 4KB

DivisionAnalysis.class 4KB

StringUtil.class 4KB

DateUtil.class 4KB

KafkaMsgProducer.class 4KB

WebLogAspect.class 4KB

DataSourceCommonProperties.class 4KB

GeoHashUtil.class 4KB

SparkUtil.class 4KB

AbstractAspect.class 3KB

TripDriveSamplePhoenixAnalysis.class 3KB

FailureAnalysisVehicleMapMysqlFunction.class 3KB

JsonPlusParseOptimize.class 3KB

JDBCUtil.class 3KB

MysqlConfig.class 3KB

HiveConfig.class 3KB

FlinkWriteToKafka.class 3KB

MysqlController.class 3KB

ElectricFenceBean.class 3KB

MySqlServiceImpl.class 3KB

FlinkWriteToKafka.class 3KB

HeatMapServiceImpl.class 3KB

GaoDeMapUtils.class 3KB

RedisUtil.class 3KB

VehicleBean.class 3KB

ElectricFenceModelFunction.class 3KB

ElectricFenceController.class 3KB

DynamicDataSourceAspect.class 3KB

HeatMapController.class 3KB

VehicleDataRateController.class 3KB

JsonPlusParse.class 3KB

testRemote.class 3KB

TestPhoenix.class 3KB

Constants.class 3KB

FailureAnalysisVehicleInfoRedisFunction.class 3KB

FlinkReadFromKafka.class 2KB

VehicleViewServiceImpl.class 2KB

SwaggerConfig.class 2KB

VehicleViewController.class 2KB

VehicleViewDaoImpl.class 2KB

DistanceCalculateUtil.class 2KB

MongoDbController.class 2KB

ParamUtil.class 2KB

DateUtil.class 2KB

ConfigUtil.class 2KB

ResponseUtil.class 2KB

VehicleDataRateBean.class 2KB

HiveController.class 2KB

ConfigLoader.class 2KB

TripDriveWatermark.class 2KB

testRemote$1.class 2KB

test.class 2KB

ElectricFenceWatermark.class 2KB

DataSourceProperties.class 2KB

DateFormatDefine.class 1KB

FlinkWriteToKafka$1.class 1KB

CorsConfig.class 1KB

MongoServiceImpl.class 1KB

JsonParse.class 1KB

ElectricFenceServiceImpl.class 1KB

共 1164 条

# Flink_Internet-of-Vehicles 基于Flink的车联网实时数据平台 ![Snipaste_2022-11-27_15-25-28](assets/Snipaste_2022-11-27_15-25-28.png) ```sql StreamingAnalysis │ pom.xml │ ├─src │ ├─main │ │ ├─java │ │ │ └─com │ │ │ └─lhq │ │ │ └─Streaming │ │ │ ├─Bean │ │ │ │ DateFormatDefine.java │ │ │ │ TripModel.java │ │ │ │ │ │ │ ├─Function │ │ │ │ TripDriveSampleWindowFunction.java │ │ │ │ TripDriveWindowFunction.java │ │ │ │ │ │ │ ├─MainTask │ │ │ │ BaseTask.java │ │ │ │ KafkaSourceDataTask.java │ │ │ │ KafkaSourceDataTaskOptimize.java │ │ │ │ TripDriveTask.java │ │ │ │ │ │ │ ├─Phoenix │ │ │ │ DivisionAnalysis.java │ │ │ │ JDBCUtil.java │ │ │ │ PhoenixJDBCUtil.java │ │ │ │ TripDivisionPhoenixAnalysis.java │ │ │ │ TripDriveSamplePhoenixAnalysis.java │ │ │ │ │ │ │ ├─Sink │ │ │ │ ToHBaseDetailSinkOptimize.java │ │ │ │ ToHBaseSink.java │ │ │ │ ToHBaseSinkOptimize.java │ │ │ │ ToHiveSink.java │ │ │ │ TripDriveSampleToHBaseSink.java │ │ │ │ TripDriveToHBaseSink.java │ │ │ │ │ │ │ ├─Source │ │ │ │ FlinkReadFromKafka.java #flink模拟kafka消费者 │ │ │ │ FlinkWriteToKafka.java #flink读取日志文件里的数据到kafka里(相当于生产者) │ │ │ │ KafkaMsgProducer.java │ │ │ │ │ │ │ ├─Utils │ │ │ │ ConfigLoader.java │ │ │ │ DateUtil.java │ │ │ │ JsonParseUtil.java │ │ │ │ StringUtil.java │ │ │ │ VehicleDataObj.java │ │ │ │ │ │ │ └─Watermark │ │ │ TripDriveWatermark.java │ │ │ │ │ └─resources │ │ conf.properties │ │ core-site.xml │ │ hbase-site.xml │ │ hdfs-site.xml │ │ logback.xml ```

评论收藏

内容反馈

版权申诉