This is an automated email from the ASF dual-hosted git repository.
wuchunfu pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
from c5a23024f [Hotfix][API] env required option can not set default value
(#3584)
add e68ecf7be [Feature][Conenctor-V2] Add openmldb source connector (#3313)
No new revisions were added by this update.
Summary of changes:
docs/en/connector-v2/source/OpenMldb.md | 85 +++++++++++
plugin-mapping.properties | 3 +-
.../pom.xml | 22 ++-
.../seatunnel/openmldb/config/OpenMldbConfig.java | 62 ++++++++
.../openmldb/config/OpenMldbParameters.java | 73 ++++++++++
.../openmldb/config/OpenMldbSqlExecutor.java | 66 +++++++++
.../exception/OpenMldbConnectorException.java} | 10 +-
.../seatunnel/openmldb/source/OpenMldbSource.java | 160 +++++++++++++++++++++
.../openmldb/source/OpenMldbSourceFactory.java} | 26 ++--
.../openmldb/source/OpenMldbSourceReader.java | 115 +++++++++++++++
seatunnel-connectors-v2/pom.xml | 1 +
seatunnel-dist/pom.xml | 5 +
12 files changed, 597 insertions(+), 31 deletions(-)
create mode 100644 docs/en/connector-v2/source/OpenMldb.md
copy seatunnel-connectors-v2/{connector-redis => connector-openmldb}/pom.xml
(79%)
create mode 100644
seatunnel-connectors-v2/connector-openmldb/src/main/java/org/apache/seatunnel/connectors/seatunnel/openmldb/config/OpenMldbConfig.java
create mode 100644
seatunnel-connectors-v2/connector-openmldb/src/main/java/org/apache/seatunnel/connectors/seatunnel/openmldb/config/OpenMldbParameters.java
create mode 100644
seatunnel-connectors-v2/connector-openmldb/src/main/java/org/apache/seatunnel/connectors/seatunnel/openmldb/config/OpenMldbSqlExecutor.java
copy
seatunnel-connectors-v2/{connector-rabbitmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rabbitmq/exception/RabbitmqConnectorException.java
=>
connector-openmldb/src/main/java/org/apache/seatunnel/connectors/seatunnel/openmldb/exception/OpenMldbConnectorException.java}
(79%)
create mode 100644
seatunnel-connectors-v2/connector-openmldb/src/main/java/org/apache/seatunnel/connectors/seatunnel/openmldb/source/OpenMldbSource.java
copy
seatunnel-connectors-v2/{connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceFactory.java
=>
connector-openmldb/src/main/java/org/apache/seatunnel/connectors/seatunnel/openmldb/source/OpenMldbSourceFactory.java}
(60%)
create mode 100644
seatunnel-connectors-v2/connector-openmldb/src/main/java/org/apache/seatunnel/connectors/seatunnel/openmldb/source/OpenMldbSourceReader.java
