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 8a5f9059a25 Docs sync done from apache/pulsar(#7b52a92)
8a5f9059a25 is described below
commit 8a5f9059a25ccb99af13ffb493534e15635646be
Author: Pulsar Site Updater <[email protected]>
AuthorDate: Thu Oct 20 12:01:40 2022 +0000
Docs sync done from apache/pulsar(#7b52a92)
---
site2/website-next/docs/io-jdbc-sink.md | 27 ++++++++++++++-------------
1 file changed, 14 insertions(+), 13 deletions(-)
diff --git a/site2/website-next/docs/io-jdbc-sink.md
b/site2/website-next/docs/io-jdbc-sink.md
index 4c9a473e027..63150517e28 100644
--- a/site2/website-next/docs/io-jdbc-sink.md
+++ b/site2/website-next/docs/io-jdbc-sink.md
@@ -15,20 +15,21 @@ 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 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.
|
-| `insertMode` | enum( INSERT,UPSERT,UPDATE) | false | INSERT |
If it is configured as UPSERT, the sink uses upsert semantics rather than plain
INSERT/UPDATE statements. Upsert semantics refer to atomically adding a new row
or updating the existing row if there is a primary key constraint violation,
which provides idempotence.
|
-| `nullValueAction` | enum(FAIL, DELETE) | false | FAIL | How
to handle records with NULL values. Possible options are `DELETE` or `FAIL`.
|
-| `useTransactions` | boolean | false | true | Enable
transactions of 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.
|
+| `insertMode` | enum( INSERT,UPSERT,UPDATE) | false | INSERT |
If it is configured as UPSERT, the sink uses upsert semantics rather than plain
INSERT/UPDATE statements. Upsert semantics refer to atomically adding a new row
or updating the existing row if there is a primary key constraint violation,
which provides idempotence.
|
+| `nullValueAction` | enum(FAIL, DELETE) | false | FAIL | How
to handle records with NULL values. Possible options are `DELETE` or `FAIL`.
|
+| `useTransactions` | boolean | false | true | Enable
transactions of the database.
| `excludeNonDeclaredFields` | boolean | false | false | All
the table fields are discovered automatically. `excludeNonDeclaredFields`
indicates if the table fields not explicitly listed in `nonKey` and `key` must
be included in the query. By default all the table fields are included. To
leverage of table fields defaults during insertion, it is suggested to set this
value to `false`. |
+| `useJdbcBatch` | boolean | false | false | Use the JDBC
batch API. This option is suggested to improve write performance. |
### Example of ClickHouse
