You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by ur...@apache.org on 2022/04/14 12:04:12 UTC
[pulsar-site] branch main updated: Docs sync done from apache/pulsar(#a19a30a)
This is an automated email from the ASF dual-hosted git repository.
urfree pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-site.git
The following commit(s) were added to refs/heads/main by this push:
new a649535b07 Docs sync done from apache/pulsar(#a19a30a)
a649535b07 is described below
commit a649535b074a154c2c19c5eaf09a091a8d79af64
Author: Pulsar Site Updater <de...@pulsar.apache.org>
AuthorDate: Thu Apr 14 12:04:07 2022 +0000
Docs sync done from apache/pulsar(#a19a30a)
---
site2/docs/io-connectors.md | 8 ++++
site2/docs/io-jdbc-sink.md | 46 +++++++++++++++-----
site2/website-next/docs/io-connectors.md | 8 ++++
site2/website-next/docs/io-jdbc-sink.md | 50 +++++++++++++++++-----
.../version-2.1.1-incubating/io-connectors.md | 8 ++++
.../versioned_docs/version-2.2.0/io-connectors.md | 8 ++++
.../versioned_docs/version-2.4.0/io-connectors.md | 8 ++++
7 files changed, 116 insertions(+), 20 deletions(-)
diff --git a/site2/docs/io-connectors.md b/site2/docs/io-connectors.md
index 1299e4997d..5a4c88d86d 100644
--- a/site2/docs/io-connectors.md
+++ b/site2/docs/io-connectors.md
@@ -194,6 +194,14 @@ Pulsar has various sink connectors, which are sorted alphabetically as below.
* [Java class](https://github.com/apache/pulsar/blob/master/pulsar-io/jdbc/mariadb/src/main/java/org/apache/pulsar/io/jdbc/MariadbJdbcAutoSchemaSink.java)
+### JDBC OpenMLDB
+
+* [Configuration](io-jdbc-sink.md#configuration)
+
+* [Example](io-jdbc-sink.md#example-for-openmldb)
+
+* [Java class](https://github.com/apache/pulsar/blob/master/pulsar-io/jdbc/openmldb/src/main/java/org/apache/pulsar/io/jdbc/OpenMLDBJdbcAutoSchemaSink.java)
+
### JDBC PostgreSQL
* [Configuration](io-jdbc-sink.md#configuration)
diff --git a/site2/docs/io-jdbc-sink.md b/site2/docs/io-jdbc-sink.md
index a54a1994d1..d3735ab5ba 100644
--- a/site2/docs/io-jdbc-sink.md
+++ b/site2/docs/io-jdbc-sink.md
@@ -15,16 +15,16 @@ The configuration of all JDBC sink connectors has the following properties.
### Property
-| Name | Type|Required | Default | Description
-|------|----------|----------|---------|-------------|
-| `userName` | String|false | " " (empty string) | The username used to connect to the database specified by `jdbcUrl`.<br><br>**Note: `userName` is case-sensitive.**|
-| `password` | String|false | " " (empty string)| The password used to connect to the database specified by `jdbcUrl`. <br><br>**Note: `password` is case-sensitive.**|
-| `jdbcUrl` | String|true | " " (empty string) | The JDBC URL of the database to which the connector connects. |
-| `tableName` | String|true | " " (empty string) | The name of the table to which the connector writes. |
-| `nonKey` | String|false | " " (empty string) | A comma-separated list contains the fields used in updating events. |
-| `key` | String|false | " " (empty string) | A comma-separated list contains the fields used in `where` condition of updating and deleting events. |
-| `timeoutMs` | int| false|500 | The JDBC operation timeout in milliseconds. |
-| `batchSize` | int|false | 200 | The batch size of updates made to the database. |
+| Name | Type | Required | Default | Description |
+|-------------|--------|----------|--------------------|--------------------------------------------------------------------------------------------------------------------------|
+| `userName` | String | false | " " (empty string) | The username used to connect to the database specified by `jdbcUrl`.<br /><br />**Note: `userName` is case-sensitive.** |
+| `password` | String | false | " " (empty string) | The password used to connect to the database specified by `jdbcUrl`. <br /><br />**Note: `password` is case-sensitive.** |
+| `jdbcUrl` | String | true | " " (empty string) | The JDBC URL of the database that the connector connects to. |
+| `tableName` | String | true | " " (empty string) | The name of the table that the connector writes to. |
+| `nonKey` | String | false | " " (empty string) | A comma-separated list containing the fields used in updating events. |
+| `key` | String | false | " " (empty string) | A comma-separated list containing the fields used in `where` condition of updating and deleting events. |
+| `timeoutMs` | int | false | 500 | The JDBC operation timeout in milliseconds. |
+| `batchSize` | int | false | 200 | The batch size of updates made to the database. |
### Example for ClickHouse
@@ -86,6 +86,32 @@ The configuration of all JDBC sink connectors has the following properties.
tableName: "pulsar_mariadb_jdbc_sink"
```
+### Example for OpenMLDB
+> OpenMLDB does not support DELETE and UPDATE operations
+* JSON
+
+ ```json
+ {
+ "configs": {
+ "jdbcUrl": "jdbc:openmldb:///pulsar_openmldb_db?zk=localhost:6181&zkPath=/openmldb",
+ "tableName": "pulsar_openmldb_jdbc_sink"
+ }
+ }
+ ```
+
+* YAML
+
+ ```yaml
+ tenant: "public"
+ namespace: "default"
+ name: "jdbc-openmldb-sink"
+ topicName: "persistent://public/default/jdbc-openmldb-topic"
+ sinkType: "jdbc-openmldb"
+ configs:
+ jdbcUrl: "jdbc:openmldb:///pulsar_openmldb_db?zk=localhost:6181&zkPath=/openmldb"
+ tableName: "pulsar_openmldb_jdbc_sink"
+ ```
+
### Example for PostgreSQL
Before using the JDBC PostgreSQL sink connector, you need to create a configuration file through one of the following methods.
diff --git a/site2/website-next/docs/io-connectors.md b/site2/website-next/docs/io-connectors.md
index 9e8ede9154..83986c8c82 100644
--- a/site2/website-next/docs/io-connectors.md
+++ b/site2/website-next/docs/io-connectors.md
@@ -194,6 +194,14 @@ Pulsar has various sink connectors, which are sorted alphabetically as below.
* [Java class](https://github.com/apache/pulsar/blob/master/pulsar-io/jdbc/mariadb/src/main/java/org/apache/pulsar/io/jdbc/MariadbJdbcAutoSchemaSink.java)
+### JDBC OpenMLDB
+
+* [Configuration](io-jdbc-sink.md#configuration)
+
+* [Example](io-jdbc-sink.md#example-for-openmldb)
+
+* [Java class](https://github.com/apache/pulsar/blob/master/pulsar-io/jdbc/openmldb/src/main/java/org/apache/pulsar/io/jdbc/OpenMLDBJdbcAutoSchemaSink.java)
+
### JDBC PostgreSQL
* [Configuration](io-jdbc-sink.md#configuration)
diff --git a/site2/website-next/docs/io-jdbc-sink.md b/site2/website-next/docs/io-jdbc-sink.md
index 0bed0e9f04..379c842988 100644
--- a/site2/website-next/docs/io-jdbc-sink.md
+++ b/site2/website-next/docs/io-jdbc-sink.md
@@ -15,16 +15,16 @@ The configuration of all JDBC sink connectors has the following properties.
### Property
-| Name | Type|Required | Default | Description
-|------|----------|----------|---------|-------------|
-| `userName` | String|false | " " (empty string) | The username used to connect to the database specified by `jdbcUrl`.<br /><br />**Note: `userName` is case-sensitive.**|
-| `password` | String|false | " " (empty string)| The password used to connect to the database specified by `jdbcUrl`. <br /><br />**Note: `password` is case-sensitive.**|
-| `jdbcUrl` | String|true | " " (empty string) | The JDBC URL of the database to which the connector connects. |
-| `tableName` | String|true | " " (empty string) | The name of the table to which the connector writes. |
-| `nonKey` | String|false | " " (empty string) | A comma-separated list contains the fields used in updating events. |
-| `key` | String|false | " " (empty string) | A comma-separated list contains the fields used in `where` condition of updating and deleting events. |
-| `timeoutMs` | int| false|500 | The JDBC operation timeout in milliseconds. |
-| `batchSize` | int|false | 200 | The batch size of updates made to the database. |
+| Name | Type | Required | Default | Description |
+|-------------|--------|----------|--------------------|--------------------------------------------------------------------------------------------------------------------------|
+| `userName` | String | false | " " (empty string) | The username used to connect to the database specified by `jdbcUrl`.<br /><br />**Note: `userName` is case-sensitive.** |
+| `password` | String | false | " " (empty string) | The password used to connect to the database specified by `jdbcUrl`. <br /><br />**Note: `password` is case-sensitive.** |
+| `jdbcUrl` | String | true | " " (empty string) | The JDBC URL of the database that the connector connects to. |
+| `tableName` | String | true | " " (empty string) | The name of the table that the connector writes to. |
+| `nonKey` | String | false | " " (empty string) | A comma-separated list containing the fields used in updating events. |
+| `key` | String | false | " " (empty string) | A comma-separated list containing the fields used in `where` condition of updating and deleting events. |
+| `timeoutMs` | int | false | 500 | The JDBC operation timeout in milliseconds. |
+| `batchSize` | int | false | 200 | The batch size of updates made to the database. |
### Example for ClickHouse
@@ -94,6 +94,36 @@ The configuration of all JDBC sink connectors has the following properties.
```
+### Example for OpenMLDB
+> OpenMLDB does not support DELETE and UPDATE operations
+* JSON
+
+ ```json
+
+ {
+ "configs": {
+ "jdbcUrl": "jdbc:openmldb:///pulsar_openmldb_db?zk=localhost:6181&zkPath=/openmldb",
+ "tableName": "pulsar_openmldb_jdbc_sink"
+ }
+ }
+
+ ```
+
+* YAML
+
+ ```yaml
+
+ tenant: "public"
+ namespace: "default"
+ name: "jdbc-openmldb-sink"
+ topicName: "persistent://public/default/jdbc-openmldb-topic"
+ sinkType: "jdbc-openmldb"
+ configs:
+ jdbcUrl: "jdbc:openmldb:///pulsar_openmldb_db?zk=localhost:6181&zkPath=/openmldb"
+ tableName: "pulsar_openmldb_jdbc_sink"
+
+ ```
+
### Example for PostgreSQL
Before using the JDBC PostgreSQL sink connector, you need to create a configuration file through one of the following methods.
diff --git a/site2/website-next/versioned_docs/version-2.1.1-incubating/io-connectors.md b/site2/website-next/versioned_docs/version-2.1.1-incubating/io-connectors.md
index 9e8ede9154..83986c8c82 100644
--- a/site2/website-next/versioned_docs/version-2.1.1-incubating/io-connectors.md
+++ b/site2/website-next/versioned_docs/version-2.1.1-incubating/io-connectors.md
@@ -194,6 +194,14 @@ Pulsar has various sink connectors, which are sorted alphabetically as below.
* [Java class](https://github.com/apache/pulsar/blob/master/pulsar-io/jdbc/mariadb/src/main/java/org/apache/pulsar/io/jdbc/MariadbJdbcAutoSchemaSink.java)
+### JDBC OpenMLDB
+
+* [Configuration](io-jdbc-sink.md#configuration)
+
+* [Example](io-jdbc-sink.md#example-for-openmldb)
+
+* [Java class](https://github.com/apache/pulsar/blob/master/pulsar-io/jdbc/openmldb/src/main/java/org/apache/pulsar/io/jdbc/OpenMLDBJdbcAutoSchemaSink.java)
+
### JDBC PostgreSQL
* [Configuration](io-jdbc-sink.md#configuration)
diff --git a/site2/website-next/versioned_docs/version-2.2.0/io-connectors.md b/site2/website-next/versioned_docs/version-2.2.0/io-connectors.md
index 9e8ede9154..83986c8c82 100644
--- a/site2/website-next/versioned_docs/version-2.2.0/io-connectors.md
+++ b/site2/website-next/versioned_docs/version-2.2.0/io-connectors.md
@@ -194,6 +194,14 @@ Pulsar has various sink connectors, which are sorted alphabetically as below.
* [Java class](https://github.com/apache/pulsar/blob/master/pulsar-io/jdbc/mariadb/src/main/java/org/apache/pulsar/io/jdbc/MariadbJdbcAutoSchemaSink.java)
+### JDBC OpenMLDB
+
+* [Configuration](io-jdbc-sink.md#configuration)
+
+* [Example](io-jdbc-sink.md#example-for-openmldb)
+
+* [Java class](https://github.com/apache/pulsar/blob/master/pulsar-io/jdbc/openmldb/src/main/java/org/apache/pulsar/io/jdbc/OpenMLDBJdbcAutoSchemaSink.java)
+
### JDBC PostgreSQL
* [Configuration](io-jdbc-sink.md#configuration)
diff --git a/site2/website-next/versioned_docs/version-2.4.0/io-connectors.md b/site2/website-next/versioned_docs/version-2.4.0/io-connectors.md
index 9e8ede9154..83986c8c82 100644
--- a/site2/website-next/versioned_docs/version-2.4.0/io-connectors.md
+++ b/site2/website-next/versioned_docs/version-2.4.0/io-connectors.md
@@ -194,6 +194,14 @@ Pulsar has various sink connectors, which are sorted alphabetically as below.
* [Java class](https://github.com/apache/pulsar/blob/master/pulsar-io/jdbc/mariadb/src/main/java/org/apache/pulsar/io/jdbc/MariadbJdbcAutoSchemaSink.java)
+### JDBC OpenMLDB
+
+* [Configuration](io-jdbc-sink.md#configuration)
+
+* [Example](io-jdbc-sink.md#example-for-openmldb)
+
+* [Java class](https://github.com/apache/pulsar/blob/master/pulsar-io/jdbc/openmldb/src/main/java/org/apache/pulsar/io/jdbc/OpenMLDBJdbcAutoSchemaSink.java)
+
### JDBC PostgreSQL
* [Configuration](io-jdbc-sink.md#configuration)