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 d106114d2af Docs sync done from apache/pulsar(#ff44420)
d106114d2af is described below
commit d106114d2af6cf820a496b2db59c8d67747ac38b
Author: Pulsar Site Updater <[email protected]>
AuthorDate: Tue Oct 18 12:01:39 2022 +0000
Docs sync done from apache/pulsar(#ff44420)
---
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 c16234f20b8..4c9a473e027 100644
--- a/site2/website-next/docs/io-jdbc-sink.md
+++ b/site2/website-next/docs/io-jdbc-sink.md
@@ -15,19 +15,20 @@ 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`. |
### Example of ClickHouse
