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/incubator-paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 36821da97 [doc] Document Spark overwrite
36821da97 is described below
commit 36821da974e87b4a5770e5b667c1aaf261f0ea88
Author: JingsongLi <[email protected]>
AuthorDate: Mon Jul 10 18:32:23 2023 +0800
[doc] Document Spark overwrite
---
docs/content/how-to/writing-tables.md | 33 ++++++++++++++++++++++++++++++---
1 file changed, 30 insertions(+), 3 deletions(-)
diff --git a/docs/content/how-to/writing-tables.md
b/docs/content/how-to/writing-tables.md
index 3a634cd50..445c3ba5c 100644
--- a/docs/content/how-to/writing-tables.md
+++ b/docs/content/how-to/writing-tables.md
@@ -138,11 +138,19 @@ INSERT INTO MyTable SELECT ...
For unpartitioned tables, Paimon supports overwriting the whole table.
+Use `INSERT OVERWRITE` to overwrite the whole unpartitioned table.
+
{{< tabs "insert-overwrite-unpartitioned-example" >}}
{{< tab "Flink" >}}
-Use `INSERT OVERWRITE` to overwrite the whole unpartitioned table.
+```sql
+INSERT OVERWRITE MyTable SELECT ...
+```
+
+{{< /tab >}}
+
+{{< tab "Spark" >}}
```sql
INSERT OVERWRITE MyTable SELECT ...
@@ -156,11 +164,19 @@ INSERT OVERWRITE MyTable SELECT ...
For partitioned tables, Paimon supports overwriting a partition.
+Use `INSERT OVERWRITE` to overwrite a partition.
+
{{< tabs "insert-overwrite-partitioned-example" >}}
{{< tab "Flink" >}}
-Use `INSERT OVERWRITE` to overwrite a partition.
+```sql
+INSERT OVERWRITE MyTable PARTITION (key1 = value1, key2 = value2, ...) SELECT
...
+```
+
+{{< /tab >}}
+
+{{< tab "Spark" >}}
```sql
INSERT OVERWRITE MyTable PARTITION (key1 = value1, key2 = value2, ...) SELECT
...
@@ -250,6 +266,7 @@ For more information of drop-partition, see
{{< /tabs >}}
## Updating tables
+
Currently, Paimon supports updating records by using `UPDATE` in Flink 1.17
and later versions. You can perform `UPDATE` in Flink's `batch` mode.
{{< hint info >}}
@@ -355,7 +372,17 @@ CREATE TABLE MyTable (
);
-- you can use
-DELETE FROM MyTable WHERE currency = 'UNKNOWN;
+DELETE FROM MyTable WHERE currency = 'UNKNOWN';
+```
+
+{{< /tab >}}
+
+{{< tab "Spark" >}}
+
+Spark `DELETE` currently supports only a single point execution, for deleting
small amounts of data.
+
+```sql
+DELETE FROM MyTable WHERE currency = 'UNKNOWN';
```
{{< /tab >}}