You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by zo...@apache.org on 2025/04/22 04:45:59 UTC
(paimon) 01/01: Revert "[doc] alter streaming write to paimon table grammar (#5499)"
This is an automated email from the ASF dual-hosted git repository.
zouxxyy pushed a commit to branch revert-5499-qingwei/alterSparkSqlWriteDoc
in repository https://gitbox.apache.org/repos/asf/paimon.git
commit c68a6b14a5b0e3d8987c3fec2308c70b0e6a57d5
Author: Zouxxyy <zo...@qq.com>
AuthorDate: Tue Apr 22 12:45:49 2025 +0800
Revert "[doc] alter streaming write to paimon table grammar (#5499)"
This reverts commit 1cf009aab458a455092415c1135acce350a8491c.
---
docs/content/spark/sql-write.md | 9 +++------
1 file changed, 3 insertions(+), 6 deletions(-)
diff --git a/docs/content/spark/sql-write.md b/docs/content/spark/sql-write.md
index 98ce312629..1f4407ef89 100644
--- a/docs/content/spark/sql-write.md
+++ b/docs/content/spark/sql-write.md
@@ -248,8 +248,7 @@ val stream = df
.outputMode("append")
.option("checkpointLocation", "/path/to/checkpoint")
.format("paimon")
- .toTable("${database}.${table}")
- // .start("/path/to/paimon/sink/table")
+ .start("/path/to/paimon/sink/table")
```
## Schema Evolution
@@ -263,8 +262,7 @@ data.write
.format("paimon")
.mode("append")
.option("write.merge-schema", "true")
- .saveAsTable("${database}.${table}")
- // .save(location)
+ .save(location)
```
When enable `write.merge-schema`, Paimon can allow users to perform the following actions on table schema by default:
@@ -285,8 +283,7 @@ inputData
.option("checkpointLocation", "/path/to/checkpoint")
.option("write.merge-schema", "true")
.option("write.merge-schema.explicit-cast", "true")
- .toTable("${database}.${table}")
- // .start(location)
+ .start(location)
```
Here list the configurations.