This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git.
from 8896bdf Merge pull request #36 from duhenglucky/main_license
new 60c38b2 fix bugs 1. leak of interface api for compile error 2. add
namesrv for RocketMQ Source
new e606e40 fix RocketMQ 4.5.2 and 4.8.0 's differences in RocketMQSource
new 06eeb45 add apache file headers
new f651ed0 Merge pull request #1 from apache/main
new 26ceaf7 Merge pull request #2 from apache/main
new 865528b Merge branch 'main' of
https://github.com/francisoliverlee/rocketmq-streams into main
new c03b1b9 fix code check fail: not ovride removeSplit() and
addNewSplit()
new a4d234a Merge pull request #35 from francisoliverlee/main
The 92 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:
.gitignore | 1 +
build_without_test.sh | 1 +
pom.xml | 6 ++
.../rocketmq/streams/source/RocketMQSource.java | 1 -
.../streams/client/source/DataStreamSource.java | 13 ++--
.../rocketmq/streams/client/DataStreamTest.java | 85 ++++++++++------------
.../streams/client/windows/WindowFromMetaq.java | 2 +-
.../streams/common/channel/AbstractChannel.java | 10 +++
.../streams/common/channel/source/ISource.java | 4 +
.../pom.xml | 39 +++++-----
.../examples/filesource/FileSourceExample.java | 16 ++--
.../rocketmqsource/RocketMQSourceExample1.java | 20 +++--
.../rocketmqsource/RocketMQSourceExample2.java | 47 ++++++++++++
13 files changed, 162 insertions(+), 83 deletions(-)
create mode 100755 build_without_test.sh
copy {rocketmq-streams-dim => rocketmq-streams-examples}/pom.xml (70%)
copy
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/StreamBuilder.java
=>
rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/filesource/FileSourceExample.java
(67%)
copy
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/StreamBuilder.java
=>
rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/rocketmqsource/RocketMQSourceExample1.java
(59%)
create mode 100644
rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/rocketmqsource/RocketMQSourceExample2.java
