⭐️
OpenMldb
OpenMldb source connector
Description
Used to read data from OpenMldb.
Key features
Options
| name | type | required | default value |
|---|---|---|---|
| cluster_mode | boolean | yes | - |
| sql | string | yes | - |
| database | string | yes | - |
| host | string | no | - |
| port | int | no | - |
| zk_path | string | no | - |
| zk_host | string | no | - |
| session_timeout | int | no | 10000 |
| request_timeout | int | no | 60000 |
| common-options | no | - |
cluster_mode [string]
OpenMldb is or not cluster mode
sql [string]
Sql statement
database [string]
Database name
host [string]
OpenMldb host, only supported on OpenMldb single mode
port [int]
OpenMldb port, only supported on OpenMldb single mode
zk_host [string]
Zookeeper host, only supported on OpenMldb cluster mode
zk_path [string]
Zookeeper path, only supported on OpenMldb cluster mode
session_timeout [int]
OpenMldb session timeout(ms), default 60000
request_timeout [int]
OpenMldb request timeout(ms), default 10000
common options
Source plugin common parameters, please refer to Source Common Options for details
Example
OpenMldb {
host = "172.17.0.2"
port = 6527
sql = "select * from demo_table1"
database = "demo_db"
cluster_mode = false
}
Changelog
Change Log
| Change | Commit | Version |
|---|---|---|
| [Improve][Common] Introduce new error define rule (#5793) | https://github.com/apache/seatunnel/commit/9d1b2582b | 2.3.4 |
| [Improve][build] Give the maven module a human readable name (#4114) | https://github.com/apache/seatunnel/commit/d7cd60105 | 2.3.1 |
| [Improve][Project] Code format with spotless plugin. (#4101) | https://github.com/apache/seatunnel/commit/a2ab16656 | 2.3.1 |
| [Feature][Connector] add get source method to all source connector (#3846) | https://github.com/apache/seatunnel/commit/417178fb8 | 2.3.1 |
| [Feature][API & Connector & Doc] add parallelism and column projection interface (#3829) | https://github.com/apache/seatunnel/commit/b9164b8ba | 2.3.1 |
| [Hotfix][OptionRule] Fix option rule about all connectors (#3592) | https://github.com/apache/seatunnel/commit/226dc6a11 | 2.3.0 |
| [Feature][Conenctor-V2] Add openmldb source connector (#3313) | https://github.com/apache/seatunnel/commit/e68ecf7be | 2.3.0 |