summaryrefslogtreecommitdiff
path: root/docs
diff options
context:
space:
mode:
authorlifengchao <[email protected]>2024-07-19 10:25:53 +0800
committerlifengchao <[email protected]>2024-07-19 10:25:53 +0800
commit0e8005ae3b8b45480e4d511c600700ac8de897ae (patch)
tree0a16f72cbea5f204745cfac63dab358d6432568c /docs
parentd17ecc5eebb7eeb48ebd6c04f9fcd7122f866525 (diff)
[feature][connector] connector source 添加watermark时间戳属性配置
Diffstat (limited to 'docs')
-rw-r--r--docs/connector/connector.md13
1 files changed, 8 insertions, 5 deletions
diff --git a/docs/connector/connector.md b/docs/connector/connector.md
index 56d3242..08ec673 100644
--- a/docs/connector/connector.md
+++ b/docs/connector/connector.md
@@ -19,11 +19,14 @@ sources:
${prop_key}: ${prop_value}
```
-| Name | Type | Required | Default | Description |
-|------------|---------------|----------|---------|--------------------------------------------------------------------------------------------------------------------------|
-| type | String | Yes | (none) | The type of the source connector. The `SourceTableFactory` will use this value as identifier to create source connector. |
-| schema | Map | No | (none) | The source table schema, config through fields or local_file or url. |
-| properties | Map of String | Yes | (none) | The source connector customize properties, more details see the [Source](source) documentation. |
+| Name | Type | Required | Default | Description |
+|--------------------------|---------------|----------|---------|--------------------------------------------------------------------------------------------------------------------------|
+| type | String | Yes | (none) | The type of the source connector. The `SourceTableFactory` will use this value as identifier to create source connector. |
+| schema | Map | No | (none) | The source table schema, config through fields or local_file or url. |
+| watermark_timestamp | String | No | (none) | watermark timestamp field name, if need use eventTime. |
+| watermark_timestamp_unit | String | No | ms | watermark field timestamp unit, options:ms(milliseconds),s(seconds). is required if watermark_timestamp is not none. |
+| watermark_lag | Long | No | (none) | watermark out-of-order milliseconds. is required if watermark_timestamp is not none. |
+| properties | Map of String | Yes | (none) | The source connector customize properties, more details see the [Source](source) documentation. |
## Schema Field Projection