[rocketmq-streams] branch main updated (35f0620 -> cec667c)

[se...@apache.org]

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

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


    from 35f0620  [ISSUE #113]Multi rocketmq source example (#113)
     new 3f65abd  fix(RocketMQSource) invoke super method
     new da59355  Merge branch 'upstream/local/main'
     new ae7d488  merge from upstream
     new 9a7e75d  add join example
     new 650e2fe  Merge branch 'upstream/local/main'
     new 10c60b0  Merge branch 'main' into develop
     new 69e0ec9  fix(RocketMQSourceExample4) join window
     new 8e83b96  merge(rocketmq-stream) main
     new 61ec996  Merge branch 'main' into develop
     new cee5d68  fix(WindowCache) window example error
     new 26b6191  docs(example) add join window example
     new 02bfdbc  fix(RocketMQSourceExample4) add license header
     new cec667c  Merge pull request #115 from ni-ze/develop

The 385 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/source/RocketMQSource.java    | 12 ++--
 .../rocketmqsource/RocketMQSourceExample4.java     | 75 ++++++++++++++++++++++
 .../src/main/resources/joinData-1.txt              |  4 ++
 .../src/main/resources/joinData-2.txt              |  4 ++
 .../rocketmq/streams/window/model/WindowCache.java | 53 +++++++--------
 5 files changed, 119 insertions(+), 29 deletions(-)
 create mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/rocketmqsource/RocketMQSourceExample4.java
 create mode 100644 rocketmq-streams-examples/src/main/resources/joinData-1.txt
 create mode 100644 rocketmq-streams-examples/src/main/resources/joinData-2.txt