Skip to content

Commit

Permalink
Merge pull request apache#147 from rocklau/rocklau-fix-example-404
Browse files Browse the repository at this point in the history
fix example code 404 in README.md
  • Loading branch information
vongosling authored Apr 11, 2022
2 parents 9db98a7 + 96fd3c7 commit 6966c93
Showing 1 changed file with 10 additions and 7 deletions.
17 changes: 10 additions & 7 deletions rocketmq-streams-examples/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -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、分时间段,统计分组中某字段的和
Expand All @@ -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 结果说明
Expand Down Expand Up @@ -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
Expand Down Expand Up @@ -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
Expand Down Expand Up @@ -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聚合。
代码目的:
Expand All @@ -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}

```
```

0 comments on commit 6966c93

Please sign in to comment.