You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by ka...@apache.org on 2022/09/08 12:38:16 UTC

[rocketmq-streams] branch main updated (45c2edc0 -> b7447bb1)

This is an automated email from the ASF dual-hosted git repository.

karp pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git


    from 45c2edc0 Merge pull request #206 from MatrixHB/add_json_serde
     new 620e19f1 remove useless code
     new 69dbdb4e add note
     new 11f565b7 Merge branch 'main' into supportRsqldb
     new d094e064 fix(watermark) support watermark
     new b7447bb1 Merge pull request #211 from ni-ze/supportRsqldb

The 565 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 rocketmq-streams-clients/pom.xml                   | 115 +--------------------
 .../streams/client/transform/WindowStream.java     |  16 +--
 .../streams/window/builder/WindowBuilder.java      |   3 +-
 .../streams/window/fire/EventTimeManager.java      |  10 +-
 .../streams/window/fire/SplitEventTimeManager.java |  24 ++---
 .../streams/window/model/WindowInstance.java       |  29 +++---
 .../streams/window/operator/AbstractWindow.java    |  12 +--
 .../window/operator/impl/SessionOperator.java      |  76 +-------------
 .../streams/window/trigger/WindowTrigger.java      |  31 +-----
 .../streams/window/WindowInstanceTest.java         |  16 +--
 10 files changed, 58 insertions(+), 274 deletions(-)