rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From xiaod...@apache.org
Subject [rocketmq-streams] branch main updated (87a3222 -> eae20f9)
Date Fri, 17 Sep 2021 02:16:33 GMT
This is an automated email from the ASF dual-hosted git repository.

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


    from 87a3222  Add Sqlmode  (#63)
     new 8d26bab  feat(rocketmq-sink) polish rocketmq topic create and rocketmq setting process
     new 3e120e1  fix(code_style) exclude rat check for test files
     new 0cfa651  fix(code_style) exclude rat check file
     new eae20f9  Merge pull request #64 from duhenglucky/main_sink

The 140 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:
 pom.xml                                            |   1 +
 .../apache/rocketmq/streams/sink/RocketMQSink.java |  73 +++++++---
 .../streams/client/transform/DataStream.java       |  53 ++++---
 .../streams/client/windows/AbstractWindowTest.java | 157 +++++++++++----------
 .../streams/client/windows/MultiSplitTest.java     |  14 +-
 .../src/test/resources/window_msg_10               |  17 ---
 .../src/test/resources/window_msg_100              |  17 ---
 .../src/test/resources/window_msg_1000             |  17 ---
 .../src/test/resources/window_msg_10000            |  17 ---
 .../src/test/resources/window_msg_88121            |  17 ---
 .../window/shuffle/AbstractSystemChannel.java      |   4 -
 11 files changed, 172 insertions(+), 215 deletions(-)

Mime
View raw message