@@ -15,6 +15,9 @@ public class FileSourceExample {
15
15
}
16
16
17
17
```
18
+ #### 1.2 代码示例
19
+
20
+ [ 代码示例 ProducerFromFile.java] ( ./../rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/ProducerFromFile.java )
18
21
19
22
20
23
### 2、分时间段,统计分组中某字段的和
@@ -40,7 +43,7 @@ public class FileSourceExample {
40
43
41
44
#### 2.3 代码示例
42
45
43
- [ 代码示例] ( ./../rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/rocketmqsource/RocketmqWindowTest .java )
46
+ [ 代码示例 RocketMQWindowExample.java ] ( ./../rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/RocketMQWindowExample .java )
44
47
45
48
46
49
#### 2.4 结果说明
@@ -75,8 +78,8 @@ data.text数据运行的结果部分如下:
75
78
{"userId":"4","eventTime":"1631700120000","method":"POST","url":"page-1"}
76
79
```
77
80
78
- #### 3.1 、统计某段时间窗口内用户点击网页次数
79
- [ 代码示例] ( ./../rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/pageclick/UsersDimension .java )
81
+ #### 3.2 、统计某段时间窗口内用户点击网页次数
82
+ [ 代码示例 UsersDimensionExample.java ] ( ./../rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/UsersDimensionExample .java )
80
83
81
84
结果:
82
85
``` xml
@@ -113,8 +116,8 @@ data.text数据运行的结果部分如下:
113
116
114
117
可查看原数据文件,eventTime为时间字段,简单检查后上述结果与预期相符合。
115
118
116
- #### 3.2 、统计某段时间窗口内,被点击次数最多的网页
117
- [ 代码示例] ( ./../rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/pageclick/PageDimension .java )
119
+ #### 3.3 、统计某段时间窗口内,被点击次数最多的网页
120
+ [ 代码示例 PageDimensionExample.java ] ( ./../rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/PageDimensionExample .java )
118
121
119
122
运行结果:
120
123
``` xml
@@ -164,7 +167,7 @@ data.text数据运行的结果部分如下:
164
167
#### 4.1、数据说明
165
168
源数据由[ data.txt] ( ./../rocketmq-streams-examples/src/main/resources/data.txt ) 组成,反复发送100遍,总共生产1000条数据。
166
169
#### 4.2、代码实例
167
- [ 代码示例] ( ./../rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/mutilconsumer/MutilStreamsClientTest .java )
170
+ [ 代码示例 MultiStreamsExample.java ] ( ./../rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/mutilconsumer/MultiStreamsExample .java )
168
171
169
172
代码中读取data.txt文件反复发送100遍,发送1000条数据。同时,开启两个消费者,每个消费者独立消费数据,然后做window聚合。
170
173
代码目的:
@@ -181,4 +184,4 @@ data.text数据运行的结果部分如下:
181
184
{"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}
182
185
{"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}
183
186
184
- ```
187
+ ```
0 commit comments