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 <[email protected]> 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(+)
