summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authordoufenghu <[email protected]>2024-11-25 13:40:37 +0800
committerdoufenghu <[email protected]>2024-11-25 15:04:18 +0800
commit5e8e348251c79098143ccbad8ebf2b9e272f1231 (patch)
tree6bee195341106f64f9344ea3e9d5343e6583e00f
parent615007ff5a45894e57766941b8cbc9c5ce866e1c (diff)
Add ARRAY_CONCAT_AGG aggregate function desc
-rw-r--r--docs/grootstream-design-cn.md20
1 files changed, 20 insertions, 0 deletions
diff --git a/docs/grootstream-design-cn.md b/docs/grootstream-design-cn.md
index 05e29ca..956fe1d 100644
--- a/docs/grootstream-design-cn.md
+++ b/docs/grootstream-design-cn.md
@@ -1816,6 +1816,26 @@ Parameters:
### 聚合函数
+#### ARRAY_CONCAT_AGG
+
+将多个数组中的各个元素连接成一个单一数组。输入类型必须为数组,字段值为NULL 将被忽略。
+
+Parameters:
+
+- mode(string): 聚合模式;可选值:`all`- 不去重(即包括重复元素);`distinct`:去重(即只保留唯一元素)。默认值:all
+- max_size(int) : 限制返回数组的最大大小。当数组长度超过该值时,裁剪掉多余的元素. 默认值:100,000
+
+```yaml
+- function: ARRAY_CONCAT_AGG
+ lookup_fields: [ tags ]
+ output_fields: [ tags ]
+ parameters:
+ mode: distinct
+ max_size: 1000
+```
+
+ ####
+
#### Collect List
在时间窗口内将指定对象合并为List,不进行去重