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 f349dd946ba29bdbc05ae958602c8b6936476d50 Merge: 6d89c9a 9c898ec Author: Heng Du <[email protected]> AuthorDate: Mon Aug 2 14:59:15 2021 +0800 Merge pull request #6 from RonzL/main add module db-operator、transport-minio rocketmq-streams-db-operator/pom.xml | 34 ++ .../rocketmq-streams-db-operator.iml | 16 + .../streams/db/configuable/DBConfigureService.java | 282 ++++++++++++ .../DBSupportParentConfigureService.java | 37 ++ .../rocketmq/streams/db/driver/DriverBuilder.java | 111 +++++ .../rocketmq/streams/db/driver/IDriverBudiler.java | 36 ++ .../rocketmq/streams/db/driver/JDBCDriver.java | 277 ++++++++++++ .../db/driver/batchloader/BatchRowLoader.java | 179 ++++++++ .../db/driver/batchloader/IRowOperator.java | 33 ++ .../rocketmq/streams/db/driver/orm/ORMUtil.java | 490 +++++++++++++++++++++ .../rocketmq/streams/db/operator/SQLOperator.java | 178 ++++++++ .../org/apache/rocketmq/streams/db/Person.java | 110 +++++ .../DBSupportParentConfigureServiceTest.java | 74 ++++ .../streams/db/driver/orm/ORMUtilTest.java | 86 ++++ rocketmq-streams-transport-minio/pom.xml | 25 ++ .../rocketmq-streams-transport-minio.iml | 17 + .../transport/minio/MinioFileTransport.java | 141 ++++++ .../yundun/dipper/configurable/DataTpyeTest.java | 70 +++ .../streams/configuable/model/DataTpyeTest.java | 68 +++ .../rocketmq/streams/configuable/model/Person.java | 97 ++++ .../streams/configurable/model/Person.java | 97 ++++ .../component/ConfigurableComponent.properties | 7 + .../src/test/resources/log4j.xml | 20 + .../src/test/resources/pro-function.txt | 11 + .../src/test/resources/python_script.py | 22 + 25 files changed, 2518 insertions(+)
