This is an automated email from the ASF dual-hosted git repository.
yux pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new f78e5eecf [FLINK-38985][docs] Add documentation for VARIANT type and
PARSE_JSON functions (#4249)
f78e5eecf is described below
commit f78e5eecfd89d295c422af39c1841c4974a9627c
Author: suhwan <[email protected]>
AuthorDate: Sat Jan 31 11:11:35 2026 +0900
[FLINK-38985][docs] Add documentation for VARIANT type and PARSE_JSON
functions (#4249)
---
docs/content.zh/docs/connectors/pipeline-connectors/paimon.md | 5 +++++
docs/content.zh/docs/core-concept/transform.md | 7 +++++++
docs/content/docs/connectors/pipeline-connectors/paimon.md | 5 +++++
docs/content/docs/core-concept/transform.md | 7 +++++++
4 files changed, 24 insertions(+)
diff --git a/docs/content.zh/docs/connectors/pipeline-connectors/paimon.md
b/docs/content.zh/docs/connectors/pipeline-connectors/paimon.md
index b269e626f..75edebc04 100644
--- a/docs/content.zh/docs/connectors/pipeline-connectors/paimon.md
+++ b/docs/content.zh/docs/connectors/pipeline-connectors/paimon.md
@@ -225,6 +225,11 @@ Pipeline 连接器配置项
<td>VARCHAR(n)</td>
<td></td>
</tr>
+ <tr>
+ <td>VARIANT</td>
+ <td>VARIANT</td>
+ <td></td>
+ </tr>
</tbody>
</table>
</div>
diff --git a/docs/content.zh/docs/core-concept/transform.md
b/docs/content.zh/docs/core-concept/transform.md
index 3a378cc86..5b56057ce 100644
--- a/docs/content.zh/docs/core-concept/transform.md
+++ b/docs/content.zh/docs/core-concept/transform.md
@@ -214,6 +214,13 @@ You can use `CAST( <EXPR> AS <T> )` syntax to convert any
valid expression `<EXP
| NUMERIC | DECIMAL | Value must be in the
range of BigDecimal(10, 0). |
| STRING, TIMESTAMP_TZ, TIMESTAMP_LTZ | TIMESTAMP | String type value must
be a valid `ISO_LOCAL_DATE_TIME` string. |
+## Variant Functions
+
+| Function | Janino Code | Description |
+| -------- | ----------- | ----------- |
+| PARSE_JSON(string[, allowDuplicateKeys]) | parseJson(string[,
allowDuplicateKeys]) | Parse a JSON string into a Variant. If the JSON string
is invalid, an error will be thrown. To return NULL instead of an error, use
the TRY_PARSE_JSON function. <br><br> If there are duplicate keys in the input
JSON string, when `allowDuplicateKeys` is true, the parser will keep the last
occurrence of all fields with the same key, otherwise it will throw an error.
The default value of `allowDuplicateKe [...]
+| TRY_PARSE_JSON(string[, allowDuplicateKeys]) | tryParseJson(string[,
allowDuplicateKeys]) | Parse a JSON string into a Variant if possible. If the
JSON string is invalid, return NULL. To throw an error instead of returning
NULL, use the PARSE_JSON function. <br><br> If there are duplicate keys in the
input JSON string, when `allowDuplicateKeys` is true, the parser will keep the
last occurrence of all fields with the same key, otherwise it will return NULL.
The default value of `allowDu [...]
+
# 示例
## 添加计算列
表达式可以用来生成新的列。例如，如果我们想基于表 `web_order` 在数据库 `mydb` 中添加两个计算列，我们可以定义一个转换规则如下：
diff --git a/docs/content/docs/connectors/pipeline-connectors/paimon.md
b/docs/content/docs/connectors/pipeline-connectors/paimon.md
index 19efb8501..d50746be0 100644
--- a/docs/content/docs/connectors/pipeline-connectors/paimon.md
+++ b/docs/content/docs/connectors/pipeline-connectors/paimon.md
@@ -225,6 +225,11 @@ Data Type Mapping
<td>VARCHAR(n)</td>
<td></td>
</tr>
+ <tr>
+ <td>VARIANT</td>
+ <td>VARIANT</td>
+ <td></td>
+ </tr>
</tbody>
</table>
</div>
diff --git a/docs/content/docs/core-concept/transform.md
b/docs/content/docs/core-concept/transform.md
index 18efeccf4..024401782 100644
--- a/docs/content/docs/core-concept/transform.md
+++ b/docs/content/docs/core-concept/transform.md
@@ -215,6 +215,13 @@ You can use `CAST( <EXPR> AS <T> )` syntax to convert any
valid expression `<EXP
| NUMERIC | DECIMAL | Value must be in the
range of BigDecimal(10, 0). |
| STRING, TIMESTAMP_TZ, TIMESTAMP_LTZ | TIMESTAMP | String type value must
be a valid `ISO_LOCAL_DATE_TIME` string. |
+## Variant Functions
+
+| Function | Janino Code | Description |
+| -------- | ----------- | ----------- |
+| PARSE_JSON(string[, allowDuplicateKeys]) | parseJson(string[,
allowDuplicateKeys]) | Parse a JSON string into a Variant. If the JSON string
is invalid, an error will be thrown. To return NULL instead of an error, use
the TRY_PARSE_JSON function. <br><br> If there are duplicate keys in the input
JSON string, when `allowDuplicateKeys` is true, the parser will keep the last
occurrence of all fields with the same key, otherwise it will throw an error.
The default value of `allowDuplicateKe [...]
+| TRY_PARSE_JSON(string[, allowDuplicateKeys]) | tryParseJson(string[,
allowDuplicateKeys]) | Parse a JSON string into a Variant if possible. If the
JSON string is invalid, return NULL. To throw an error instead of returning
NULL, use the PARSE_JSON function. <br><br> If there are duplicate keys in the
input JSON string, when `allowDuplicateKeys` is true, the parser will keep the
last occurrence of all fields with the same key, otherwise it will return NULL.
The default value of `allowDu [...]
+
# Example
## Add computed columns
Evaluation expressions can be used to generate new columns. For example, if we
want to append two computed columns based on the table `web_order` in the
database `mydb`, we may define a transform rule as follows:
