summaryrefslogtreecommitdiff
path: root/docs/processor
diff options
context:
space:
mode:
author王宽 <[email protected]>2024-11-21 09:22:34 +0000
committer王宽 <[email protected]>2024-11-21 09:22:34 +0000
commit6597e6729c69a4a93ec7d54c7e376c258e40d708 (patch)
tree6b0050d5e3afcd1e59706fab8f8372dd606e353f /docs/processor
parente39efc6b9e48bbb2df25685cd02f1292c4035569 (diff)
Update udaf.md
Diffstat (limited to 'docs/processor')
-rw-r--r--docs/processor/udaf.md10
1 files changed, 8 insertions, 2 deletions
diff --git a/docs/processor/udaf.md b/docs/processor/udaf.md
index f305201..90565fc 100644
--- a/docs/processor/udaf.md
+++ b/docs/processor/udaf.md
@@ -42,13 +42,16 @@ COLLECT_LIST is used to collect the value of the field in the group of events.
- filter: optional
- lookup_fields: required. Now only support one field.
- output_fields: optional. If not set, the output field name is `lookup_field_name`.
-
+ - parameters: optional.
+ - collect_type: `<String>` optional. input field type can be `array` or `object`. Default is `object`. If set to array, the function processes each element of the array individually.If set to object, the function treats the entire input object as a single element.
Example:
```yaml
- function: COLLECT_LIST
lookup_fields: [client_ip]
output_fields: [client_ip_list]
+ - parameters:
+ - collect_type: object
```
### Collect Set
@@ -60,13 +63,16 @@ COLLECT_SET is used to collect the unique value of the field in the group of eve
- filter: optional
- lookup_fields: required. Now only support one field.
- output_fields: optional. If not set, the output field name is `lookup_field_name`.
-
+ - parameters: optional.
+ - collect_type: `<String>` optional. input field type can be `array` or `object`. Default is `object`. If set to array, the function expands the elements of the array and removes duplicates.If set to object, the function treats the entire input object as a single element and removes duplicates.
Example
```yaml
- function: COLLECT_SET
lookup_fields: [client_ip]
output_fields: [client_ip_set]
+ - parameters:
+ - collect_type: array
```
### First Value