[rocketmq-streams] branch main updated: fix example code 404 in README.md

[vongosling]

This is an automated email from the ASF dual-hosted git repository.

vongosling pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git


The following commit(s) were added to refs/heads/main by this push:
     new c14fce9  fix example code 404 in README.md
     new ba17e0d  Merge pull request #147 from rocklau/rocklau-fix-example-404
c14fce9 is described below

commit c14fce95df735f1f03b46e0a470c6656a0fbc557
Author: Rocky Liu <rockla...@gmail.com>
AuthorDate: Fri Apr 8 21:15:10 2022 +0800

    fix example code 404 in README.md
    
    improve readability
    fix example code 404
---
 rocketmq-streams-examples/README.md | 17 ++++++++++-------
 1 file changed, 10 insertions(+), 7 deletions(-)

diff --git a/rocketmq-streams-examples/README.md 
b/rocketmq-streams-examples/README.md
index 16c7d38..80a6c94 100644
--- a/rocketmq-streams-examples/README.md
+++ b/rocketmq-streams-examples/README.md
@@ -15,6 +15,9 @@ public class FileSourceExample {
 }
 
 ```
+#### 1.2 代码示例
+
+[代码示例 
ProducerFromFile.java](./../rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/ProducerFromFile.java)
 
 
 ### 2、分时间段，统计分组中某字段的和
@@ -40,7 +43,7 @@ public class FileSourceExample {
 
 #### 2.3 代码示例
 
-[代码示例](./../rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/rocketmqsource/RocketmqWindowTest.java)
+[代码示例 
RocketMQWindowExample.java](./../rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/RocketMQWindowExample.java)
 
 
 #### 2.4 结果说明
@@ -75,8 +78,8 @@ data.text数据运行的结果部分如下：
 {"userId":"4","eventTime":"1631700120000","method":"POST","url":"page-1"}
 ```
 
-#### 3.1、统计某段时间窗口内用户点击网页次数
-[代码示例](./../rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/pageclick/UsersDimension.java)
+#### 3.2、统计某段时间窗口内用户点击网页次数
+[代码示例 
UsersDimensionExample.java](./../rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/UsersDimensionExample.java)
 
 结果：
 ```xml
@@ -113,8 +116,8 @@ data.text数据运行的结果部分如下：
 
 可查看原数据文件，eventTime为时间字段，简单检查后上述结果与预期相符合。
 
-#### 3.2、统计某段时间窗口内，被点击次数最多的网页
-[代码示例](./../rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/pageclick/PageDimension.java)
+#### 3.3、统计某段时间窗口内，被点击次数最多的网页
+[代码示例 
PageDimensionExample.java](./../rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/PageDimensionExample.java)
 
 运行结果：
 ```xml
@@ -164,7 +167,7 @@ data.text数据运行的结果部分如下：
 #### 4.1、数据说明
 
源数据由[data.txt](./../rocketmq-streams-examples/src/main/resources/data.txt)组成，反复发送100遍，总共生产1000条数据。
 #### 4.2、代码实例
-[代码示例](./../rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/mutilconsumer/MutilStreamsClientTest.java)
+[代码示例 
MultiStreamsExample.java](./../rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/mutilconsumer/MultiStreamsExample.java)
 
 代码中读取data.txt文件反复发送100遍，发送1000条数据。同时，开启两个消费者，每个消费者独立消费数据，然后做window聚合。
 代码目的：
@@ -181,4 +184,4 @@ data.text数据运行的结果部分如下：
 {"start_time":"2021-09-27 
14:10:20","InFlow":720,"total":144,"windowInstanceId":"4YnbFAgSzeDt5qpo+Is/5w==","offset":54915035100000002,"ProjectName":"ProjectName-1","LogStore":"LogStore-1","end_time":"2021-09-27
 14:10:30","OutFlow":576}
 {"start_time":"2021-09-27 
14:10:20","InFlow":864,"total":144,"windowInstanceId":"4YnbFAgSzeDt5qpo+Is/5w==","offset":54915035100000003,"ProjectName":"ProjectName-2","LogStore":"LogStore-2","end_time":"2021-09-27
 14:10:30","OutFlow":720}
 
-```
\ No newline at end of file
+```