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/03 06:50:48 UTC

[rocketmq-streams] 20/35: Merge pull request #6 from RonzL/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 f349dd946ba29bdbc05ae958602c8b6936476d50
Merge: 6d89c9a 9c898ec
Author: Heng Du <du...@apache.org>
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(+)