search

apache / rocketmq-streams

Apache rocketmq
https://rocketmq.apache.org/
Apache License 2.0
171 stars 82 forks source link

[ISSUE # 250 & 249 & 248] Support sum&min&max function in WindowStream #275

Closed joeCarf closed 1 year ago

joeCarf commented 1 year ago

issue: https://github.com/apache/rocketmq-streams/issues/250 issue : https://github.com/apache/rocketmq-streams/issues/249 issue: https://github.com/apache/rocketmq-streams/issues/248

ni-ze commented 1 year ago

can you give the origin data and result of examples? @joeCarf

joeCarf commented 1 year ago

Input and outputs of examples: Input:

input

WindowSum output:

windowSum

WindowMin output: windowMin

WindowMax output: windowMax

ni-ze commented 1 year ago

@joeCarf the result is correct. please don't use event_time in example, because if your time not change in data. The data will be discarded when you send at second time.