You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by "joeCarf (via GitHub)" <gi...@apache.org> on 2023/02/20 13:51:01 UTC
[GitHub] [rocketmq-streams] joeCarf opened a new pull request, #275: [ISSUE #249 & 248] Support min&max function in WindowStream
joeCarf opened a new pull request, #275:
URL: https://github.com/apache/rocketmq-streams/pull/275
issue : https://github.com/apache/rocketmq-streams/issues/249
issue: https://github.com/apache/rocketmq-streams/issues/248
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-streams] ni-ze merged pull request #275: [ISSUE # 250 & 249 & 248] Support sum&min&max function in WindowStream
Posted by "ni-ze (via GitHub)" <gi...@apache.org>.
ni-ze merged PR #275:
URL: https://github.com/apache/rocketmq-streams/pull/275
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-streams] ni-ze commented on pull request #275: [ISSUE # 250 & 249 & 248] Support sum&min&max function in WindowStream
Posted by "ni-ze (via GitHub)" <gi...@apache.org>.
ni-ze commented on PR #275:
URL: https://github.com/apache/rocketmq-streams/pull/275#issuecomment-1439402412
can you give the origin data and result of examples?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-streams] ni-ze commented on pull request #275: [ISSUE # 250 & 249 & 248] Support sum&min&max function in WindowStream
Posted by "ni-ze (via GitHub)" <gi...@apache.org>.
ni-ze commented on PR #275:
URL: https://github.com/apache/rocketmq-streams/pull/275#issuecomment-1442839573
@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.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-streams] joeCarf commented on pull request #275: [ISSUE # 250 & 249 & 248] Support sum&min&max function in WindowStream
Posted by "joeCarf (via GitHub)" <gi...@apache.org>.
joeCarf commented on PR #275:
URL: https://github.com/apache/rocketmq-streams/pull/275#issuecomment-1441097146
Input and outputs of examples:
Input:
<img width="757" alt="input" src="https://user-images.githubusercontent.com/52153761/220799448-8504472c-7e6d-4c60-8818-74c09bedb9f7.png">
WindowSum output:
<img width="828" alt="windowSum" src="https://user-images.githubusercontent.com/52153761/220799491-a78c885e-5c4a-4834-85aa-ad44d17111f9.png">
WindowMin output:
WindowMax output:
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org