This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 40c89b5a5b [doc] Add spark dataframe read and write (#5363)
40c89b5a5b is described below
commit 40c89b5a5b3f6a7b711af041d90333c9cb640504
Author: Zouxxyy <[email protected]>
AuthorDate: Thu Mar 27 23:09:11 2025 +0800
[doc] Add spark dataframe read and write (#5363)
---
docs/content/spark/quick-start.md | 29 +++++++++++++++++++++++++++--
1 file changed, 27 insertions(+), 2 deletions(-)
diff --git a/docs/content/spark/quick-start.md
b/docs/content/spark/quick-start.md
index ec86918ae6..dea69636f5 100644
--- a/docs/content/spark/quick-start.md
+++ b/docs/content/spark/quick-start.md
@@ -177,10 +177,32 @@ tblproperties (
## Insert Table
+{{< tabs "Insert Paimon Table" >}}
+
+{{< tab "SQL" >}}
+
```sql
INSERT INTO my_table VALUES (1, 'Hi'), (2, 'Hello');
```
+{{< /tab >}}
+
+{{< tab "DataFrame" >}}
+
+```scala
+-- you can use
+Seq((1, "Hi"), (2, "Hello")).toDF("k", "v")
+ .write.format("paimon").mode("append").saveAsTable("my_table")
+
+-- or
+Seq((1, "Hi"), (2, "Hello")).toDF("k", "v")
+
.write.format("paimon").mode("append").save("file:/tmp/paimon/default.db/my_table")
+```
+
+{{< /tab >}}
+
+{{< /tabs >}}
+
## Query Table
{{< tabs "Query Paimon Table" >}}
@@ -201,8 +223,11 @@ SELECT * FROM my_table;
{{< tab "DataFrame" >}}
```scala
-val dataset =
spark.read.format("paimon").load("file:/tmp/paimon/default.db/my_table")
-dataset.show()
+-- you can use
+spark.read.format("paimon").table("my_table").show()
+
+-- or
+spark.read.format("paimon").load("file:/tmp/paimon/default.db/my_table").show()
/*
+---+------+
