This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git.
from f349dd9 Merge pull request #6 from RonzL/main
new ed97ca3 add channel-db module
new 1992a35 add channel-configurable
new 5ef7b1d Merge pull request #5 from cw68ster/main
The 15 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 | 8 +-
.../streams/db/sink/AbstractMultiTableSink.java | 150 ++++++
.../apache/rocketmq/streams/db/sink/DBSink.java | 239 +++++++++
.../rocketmq/streams/db/sink/DBSinkBuilder.java | 76 +++
.../streams/db/sink/SelfMultiTableSink.java | 53 ++
.../streams/db/sink/SplitBySerialNumber.java | 23 +-
.../streams/db/sink/SplitByTimeMultiTableSink.java | 23 +-
.../streams/db/sink/db/DBWriteOnlyChannelTest.java | 84 +++
.../pom.xml | 8 +-
.../streams/configuable/ConfigurableComponent.java | 189 +++++++
.../streams/configuable/model/Configure.java | 130 +++++
.../service/AbstractConfigurableService.java | 561 +++++++++++++++++++++
.../AbstractSupportParentConfigureService.java | 263 ++++++++++
.../service/ConfigurableServcieType.java | 22 +-
.../service/ConfigurableServiceFactory.java | 58 +++
.../service/impl/FileConfigureService.java | 250 +++++++++
.../impl/FileSupportParentConfigureService.java | 17 +-
.../service/impl/MemoryConfigureService.java | 122 +++++
.../impl/MemorySupportParentConfigureService.java | 20 +-
.../configurable/ConfigurableComponent.java | 188 +++++++
.../streams/configurable/model/Configure.java | 127 +++++
.../service/AbstractConfigurableService.java | 553 ++++++++++++++++++++
.../AbstractSupportParentConfigureService.java | 255 ++++++++++
.../service/ConfigurableServcieType.java | 15 +-
.../service/ConfigurableServiceFactory.java | 59 +++
.../service/impl/FileConfigureService.java | 249 +++++++++
.../impl/FileSupportParentConfigureService.java | 14 +-
.../service/impl/MemoryConfigureService.java | 121 +++++
.../impl/MemorySupportParentConfigureService.java | 18 +-
.../src/main}/resources/log4j.xml | 0
.../configuable/ConfiguableComponentTest.java | 112 ++++
.../streams/configuable/model}/Person.java | 8 +-
.../configurable/ConfigurableComponentTest.java | 108 ++++
.../streams/configurable/model}/Person.java | 2 +-
.../src/test/resources/log4j.xml | 0
35 files changed, 4030 insertions(+), 95 deletions(-)
copy {rocketmq-streams-lease => rocketmq-streams-channel-db}/pom.xml (73%)
create mode 100644
rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/AbstractMultiTableSink.java
create mode 100644
rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/DBSink.java
create mode 100644
rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/DBSinkBuilder.java
create mode 100644
rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/SelfMultiTableSink.java
copy
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/strategy/StateStrategy.java
=>
rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/SplitBySerialNumber.java
(61%)
copy
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/strategy/StateStrategy.java
=>
rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/SplitByTimeMultiTableSink.java
(60%)
create mode 100644
rocketmq-streams-channel-db/src/test/java/org/apache/rocketmq/streams/db/sink/db/DBWriteOnlyChannelTest.java
copy {rocketmq-streams-transport-minio =>
rocketmq-streams-configurable}/pom.xml (74%)
create mode 100644
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configuable/ConfigurableComponent.java
create mode 100644
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configuable/model/Configure.java
create mode 100644
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configuable/service/AbstractConfigurableService.java
create mode 100644
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configuable/service/AbstractSupportParentConfigureService.java
copy
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/strategy/StateStrategy.java
=>
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configuable/service/ConfigurableServcieType.java
(59%)
create mode 100644
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configuable/service/ConfigurableServiceFactory.java
create mode 100644
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configuable/service/impl/FileConfigureService.java
copy
rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/configuable/DBSupportParentConfigureService.java
=>
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configuable/service/impl/FileSupportParentConfigureService.java
(68%)
create mode 100644
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configuable/service/impl/MemoryConfigureService.java
copy
rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/configuable/DBSupportParentConfigureService.java
=>
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configuable/service/impl/MemorySupportParentConfigureService.java
(64%)
create mode 100644
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/ConfigurableComponent.java
create mode 100644
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/model/Configure.java
create mode 100644
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/AbstractConfigurableService.java
create mode 100644
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/AbstractSupportParentConfigureService.java
copy
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/StreamBuilder.java
=>
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/ConfigurableServcieType.java
(59%)
create mode 100644
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/ConfigurableServiceFactory.java
create mode 100644
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/impl/FileConfigureService.java
copy
rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/configuable/DBSupportParentConfigureService.java
=>
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/impl/FileSupportParentConfigureService.java
(78%)
create mode 100644
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/impl/MemoryConfigureService.java
copy
rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/configuable/DBSupportParentConfigureService.java
=>
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/impl/MemorySupportParentConfigureService.java
(74%)
copy {rocketmq-streams-transport-minio/src/test =>
rocketmq-streams-configurable/src/main}/resources/log4j.xml (100%)
create mode 100644
rocketmq-streams-configurable/src/test/java/org/apache/rocketmq/streams/configuable/ConfiguableComponentTest.java
copy
{rocketmq-streams-db-operator/src/test/java/org/apache/rocketmq/streams/db =>
rocketmq-streams-configurable/src/test/java/org/apache/rocketmq/streams/configuable/model}/Person.java
(95%)
create mode 100644
rocketmq-streams-configurable/src/test/java/org/apache/rocketmq/streams/configurable/ConfigurableComponentTest.java
copy
{rocketmq-streams-db-operator/src/test/java/org/apache/rocketmq/streams/db =>
rocketmq-streams-configurable/src/test/java/org/apache/rocketmq/streams/configurable/model}/Person.java
(98%)
copy {rocketmq-streams-transport-minio =>
rocketmq-streams-configurable}/src/test/resources/log4j.xml (100%)
