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/06/21 03:55:09 UTC

[rocketmq-streams] 10/16: Merge branch 'replaceDB' into devForEnterprise

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

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

commit f1d507c043872553fcc4841876f307ddc36d35c6
Merge: 5e91a37a ff92d26b
Author: 维章 <un...@gmail.com>
AuthorDate: Mon May 30 10:16:25 2022 +0800

    Merge branch 'replaceDB' into devForEnterprise

 .../streams/source/MessageListenerDelegator.java   | 12 +++++-
 .../rocketmq/streams/source/RocketMQSource.java    | 44 ++++++++++++++--------
 .../streams/examples/join/RocketmqJoinExample.java |  2 +-
 .../streams/window/operator/AbstractWindow.java    |  1 -
 4 files changed, 40 insertions(+), 19 deletions(-)