This is an automated email from the ASF dual-hosted git repository. dinglei pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
commit baa9856ffcf1e062fbf3789fe2e1e09fd8901efc Merge: 229c673 3c58757 Author: dinglei <[email protected]> AuthorDate: Fri Apr 1 15:26:16 2022 +0800 [ISSUE #12] [Part 2] Support transforms [ISSUE #12] [Part 2] Support transforms pom.xml | 6 + rocketmq-connect-runtime/pom.xml | 4 + .../runtime/config/RuntimeConfigDefine.java | 2 + .../runtime/connectorwrapper/TransformChain.java | 123 +++++++++++++++++++++ .../connect/runtime/connectorwrapper/Worker.java | 9 +- .../runtime/connectorwrapper/WorkerSinkTask.java | 20 +++- .../runtime/connectorwrapper/WorkerSourceTask.java | 16 ++- .../rocketmq/connect/runtime/utils/Plugin.java | 2 + .../runtime/connectorwrapper/WorkerTest.java | 8 +- .../connect/runtime/rest/RestHandlerTest.java | 9 +- 10 files changed, 186 insertions(+), 13 deletions(-)
