Skip to content

Commit

Permalink
Update README.md
Browse files Browse the repository at this point in the history
  • Loading branch information
linwt committed Oct 1, 2018
1 parent c741f9e commit 6a13f4a
Showing 1 changed file with 6 additions and 3 deletions.
9 changes: 6 additions & 3 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,8 @@ SparkMLlib智慧交通项目
--zookeeper mini1:2181 \
--topic traffic \
--from-beginning
6. 运行程序Producer
6. 运行程序Producer<br><br>
![produce](https://github.com/linwt/TrafficForecast-SparkMLlib/blob/master/picture/produce.png)
### 消费者模块
- 功能:消费kafka数据,并将处理后的数据存储到Redis中
- 操作步骤
Expand All @@ -46,10 +47,12 @@ SparkMLlib智慧交通项目
3. 查看Redis数据库
> 127.0.0.1:6379> select 1 \
> 127.0.0.1:6379[1]> keys * \
> 127.0.0.1:6379[1]> hgetall “20180412_0001”
> 127.0.0.1:6379[1]> hgetall “20180823_0015”<br><br>
![redis](https://github.com/linwt/TrafficForecast-SparkMLlib/blob/master/picture/redis.png)
### 数据建模模块
- 功能:读取Redis数据库数据,进行数据建模,并将模型保存到hdfs
- 操作步骤
1. 运行程序Train
2. web访问hdfs,查看保存结果
> mini1:50070
> mini1:50070<br><br>
![labelPoint](https://github.com/linwt/TrafficForecast-SparkMLlib/blob/master/picture/labelPoint.png)

0 comments on commit 6a13f4a

Please sign in to comment.