You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by lz...@apache.org on 2023/12/27 11:13:51 UTC
(incubator-paimon) branch master updated: [core] Fix nested-update to nested_update
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 e3d3132eb [core] Fix nested-update to nested_update
e3d3132eb is described below
commit e3d3132ebc64f33c7b1952ab3850ddf3e3ed3670
Author: Jingsong <ji...@gmail.com>
AuthorDate: Wed Dec 27 19:13:21 2023 +0800
[core] Fix nested-update to nested_update
---
docs/content/concepts/primary-key-table.md | 8 ++++----
.../paimon/mergetree/compact/aggregate/FieldNestedUpdateAgg.java | 2 +-
.../test/java/org/apache/paimon/flink/PreAggregationITCase.java | 4 ++--
3 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/docs/content/concepts/primary-key-table.md b/docs/content/concepts/primary-key-table.md
index 772c403e3..288c7a865 100644
--- a/docs/content/concepts/primary-key-table.md
+++ b/docs/content/concepts/primary-key-table.md
@@ -326,14 +326,14 @@ Current supported aggregate functions and data types are:
The first_not_null_value function selects the first non-null value in a data set.
It supports all data types.
-* `nested-update`:
- The nested-update function collects multiple rows into one array<row> (so-called 'nested table'). It supports ARRAY<ROW> data types.
+* `nested_update`:
+ The nested_update function collects multiple rows into one array<row> (so-called 'nested table'). It supports ARRAY<ROW> data types.
Use `fields.<field-name>.nested-key=pk0,pk1,...` to specify the primary keys of the nested table. If no keys, row will be appended to array<row>.
An example:
- {{< tabs "nested-update-example" >}}
+ {{< tabs "nested_update-example" >}}
{{< tab "Flink" >}}
@@ -363,7 +363,7 @@ Current supported aggregate functions and data types are:
sub_orders ARRAY<ROW<sub_order_id BIGINT, product_name STRING, price BIGINT>>
) WITH (
'merge-engine' = 'aggregation',
- 'fields.sub_orders.aggregate-function' = 'nested-update',
+ 'fields.sub_orders.aggregate-function' = 'nested_update',
'fields.sub_orders.nested-key' = 'sub_order_id'
);
diff --git a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldNestedUpdateAgg.java b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldNestedUpdateAgg.java
index 9a3c79c79..69e2736ce 100644
--- a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldNestedUpdateAgg.java
+++ b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldNestedUpdateAgg.java
@@ -40,7 +40,7 @@ import java.util.Map;
*/
public class FieldNestedUpdateAgg extends FieldAggregator {
- public static final String NAME = "nested-update";
+ public static final String NAME = "nested_update";
private final int nestedFields;
diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PreAggregationITCase.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PreAggregationITCase.java
index 9b5fb6dbf..63670eb7c 100644
--- a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PreAggregationITCase.java
+++ b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PreAggregationITCase.java
@@ -1006,7 +1006,7 @@ public class PreAggregationITCase {
+ " sub_orders ARRAY<ROW<daily_id INT, today STRING, product_name STRING, price BIGINT>>\n"
+ ") WITH (\n"
+ " 'merge-engine' = 'aggregation',\n"
- + " 'fields.sub_orders.aggregate-function' = 'nested-update',\n"
+ + " 'fields.sub_orders.aggregate-function' = 'nested_update',\n"
+ " 'fields.sub_orders.nested-key' = 'daily_id,today',\n"
+ " 'fields.sub_orders.ignore-retract' = 'true',"
+ " 'fields.user_name.ignore-retract' = 'true',"
@@ -1021,7 +1021,7 @@ public class PreAggregationITCase {
+ " sub_orders ARRAY<ROW<daily_id INT, today STRING, product_name STRING, price BIGINT>>\n"
+ ") WITH (\n"
+ " 'merge-engine' = 'aggregation',\n"
- + " 'fields.sub_orders.aggregate-function' = 'nested-update',\n"
+ + " 'fields.sub_orders.aggregate-function' = 'nested_update',\n"
+ " 'fields.sub_orders.ignore-retract' = 'true',"
+ " 'fields.user_name.ignore-retract' = 'true',"
+ " 'fields.address.ignore-retract' = 'true'"