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

  2.   OpenMldb {
  3.     host = "172.17.0.2"
  4.     port = 6527
  5.     sql = "select * from demo_table1"
  6.     database = "demo_db"
  7.     cluster_mode = false
  8.   }