Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

fix example code 404 in README.md #147

Merged
merged 1 commit into from
Apr 11, 2022
Merged

fix example code 404 in README.md #147

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
17 changes: 10 additions & 7 deletions rocketmq-streams-examples/README.md
View file
Open in desktop
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}

```
```