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(-)
