You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2021/08/05 12:54:26 UTC
[rocketmq-streams] 28/46: Merge pull request #5 from cw68ster/main

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

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

commit 5ef7b1d40a99262078430f691fed2afa8c8352c2
Merge: f349dd9 1992a35
Author: rongtong <ji...@163.com>
AuthorDate: Mon Aug 2 18:55:10 2021 +0800

    Merge pull request #5 from cw68ster/main
    
    add module channel-db,channel-configurable

 rocketmq-streams-channel-db/pom.xml                |  21 +
 .../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       |  36 ++
 .../streams/db/sink/SplitByTimeMultiTableSink.java |  36 ++
 .../streams/db/sink/db/DBWriteOnlyChannelTest.java |  84 +++
 rocketmq-streams-configurable/pom.xml              |  21 +
 .../streams/configuable/ConfigurableComponent.java | 189 +++++++
 .../streams/configuable/model/Configure.java       | 130 +++++
 .../service/AbstractConfigurableService.java       | 561 +++++++++++++++++++++
 .../AbstractSupportParentConfigureService.java     | 263 ++++++++++
 .../service/ConfigurableServcieType.java           |  31 ++
 .../service/ConfigurableServiceFactory.java        |  58 +++
 .../service/impl/FileConfigureService.java         | 250 +++++++++
 .../impl/FileSupportParentConfigureService.java    |  38 ++
 .../service/impl/MemoryConfigureService.java       | 122 +++++
 .../impl/MemorySupportParentConfigureService.java  |  39 ++
 .../configurable/ConfigurableComponent.java        | 188 +++++++
 .../streams/configurable/model/Configure.java      | 127 +++++
 .../service/AbstractConfigurableService.java       | 553 ++++++++++++++++++++
 .../AbstractSupportParentConfigureService.java     | 255 ++++++++++
 .../service/ConfigurableServcieType.java           |  29 ++
 .../service/ConfigurableServiceFactory.java        |  59 +++
 .../service/impl/FileConfigureService.java         | 249 +++++++++
 .../impl/FileSupportParentConfigureService.java    |  37 ++
 .../service/impl/MemoryConfigureService.java       | 121 +++++
 .../impl/MemorySupportParentConfigureService.java  |  37 ++
 .../src/main/resources/log4j.xml                   |  20 +
 .../configuable/ConfiguableComponentTest.java      | 112 ++++
 .../rocketmq/streams/configuable/model/Person.java | 110 ++++
 .../configurable/ConfigurableComponentTest.java    | 108 ++++
 .../streams/configurable/model/Person.java         | 110 ++++
 .../src/test/resources/log4j.xml                   |  20 +
 35 files changed, 4532 insertions(+)