OpenMldb

OpenMldb 源连接器

描述

用于从 OpenMldb 读取数据.

关键特性

• 批处理
• 流处理
• 精确一次
• 列投影
• 并行度
• 支持用户自定义分片

选项

名称	类型	必需	默认值
cluster_mode	boolean	是	-
sql	string	是	-
database	string	是	-
host	string	否	-
port	int	否	-
zk_path	string	否	-
zk_host	string	否	-
session_timeout	int	否	10000
request_timeout	int	否	60000
common-options		否	-

cluster_mode [string]

OpenMldb 是否处于群集模式

sql [string]

Sql 语句

database [string]

数据库名称

host [string]

OpenMldb主机，仅支持OpenMldb单模

port [int]

OpenMldb端口，仅支持OpenMldb单模

zk_host [string]

Zookeeper主机，仅在OpenMldb集群模式下受支持

zk_path [string]

Zookeeper路径，仅在OpenMldb集群模式下受支持

session_timeout [int]

OpenMldb会话超时（ms），默认值60000

request_timeout [int]

OpenMldb请求超时（ms），默认值为10000

common options

源插件常用参数, 详见 Source Common Options

示例

  OpenMldb {
    host = "172.17.0.2"
    port = 6527
    sql = "select * from demo_table1"
    database = "demo_db"
    cluster_mode = false
  }

变更日志

Change Log

Change	Commit	Version
[Improve][Common] Introduce new error define rule (#5793)	https://github.com/apache/seatunnel/commit/9d1b2582b2	2.3.4
[Improve][build] Give the maven module a human readable name (#4114)	https://github.com/apache/seatunnel/commit/d7cd601051	2.3.1
[Improve][Project] Code format with spotless plugin. (#4101)	https://github.com/apache/seatunnel/commit/a2ab166561	2.3.1
[Feature][Connector] add get source method to all source connector (#3846)	https://github.com/apache/seatunnel/commit/417178fb84	2.3.1
[Feature][API & Connector & Doc] add parallelism and column projection interface (#3829)	https://github.com/apache/seatunnel/commit/b9164b8ba1	2.3.1
[Hotfix][OptionRule] Fix option rule about all connectors (#3592)	https://github.com/apache/seatunnel/commit/226dc6a119	2.3.0
[Feature][Conenctor-V2] Add openmldb source connector (#3313)	https://github.com/apache/seatunnel/commit/e68ecf7bef	2.3.0