数组处理

概述

数组处理节点，支持12种不同的数组操作类型，包括转换、合并、查询、计算等功能。通过丰富的数组操作能力，可以实现复杂的数据处理、格式转换和分析需求。

功能特性

12种处理类型：涵盖数组转换、合并、查询、计算等全方位功能

灵活数据处理：支持对象数组、键值对、嵌套结构等复杂数据类型

智能类型转换：自动处理数据类型转换和格式化

性能优化：使用流式处理优化大数据集操作

错误处理：完善的异常捕获和错误信息返回

支持的操作类型

1. ARRAYTOTEXT - 数组转文本

将数组元素转换为用指定分隔符连接的字符串。

参数：

input：输入数组

join：分隔符（默认逗号）

输出：连接后的字符串

2. ARRAY_MERGE - 数组合并

将两个数组按指定位置合并。

参数：

baseArray：基础数组

supplementArray：补充数组

mergePosition：合并位置（"start"或"end"）

输出：合并后的数组

3. CREATEOBJECTARRAY - 创建对象数组

从Map数据创建对象数组，每个数组元素为一个对象。

参数：

input：包含多个List的Map

输出：对象数组

4. CREATEKEYVALUE_PAIRS - 创建键值对数组

将键数组和值数组组合成键值对数组。

参数：

keys：键数组

values：值数组

输出：键值对对象数组

5. TEXTTOARRAY - 文本转数组

将Map对象转换为数组格式。

参数：

input：输入Map对象

输出：包含keyValue和values的Map

6. GETBYINDEX - 按索引查询

根据索引获取数组中的元素。

参数：

input：输入数组

index：索引值

输出：指定索引的元素

7. INSERT_ELEMENT - 插入元素

在数组指定位置插入元素或数组。

参数：

input：输入数组

index：插入位置

element：要插入的元素

输出：插入后的数组

8. NESTED_AGGREGATE - 嵌套聚合

从嵌套对象数组中提取指定路径的值并聚合。

参数：

input：输入对象数组

aggregatePathMap：路径映射Map

输出：聚合后的字段数组

9. ARRAY_CALCULATE - 数组计算

对数组进行各种数学计算和判断操作。

支持的计算类型：

sum：求和

count：计数

avg：平均值

max：最大值

min：最小值

contains_string：判断是否包含字符串

contains_number：判断是否包含数字

check_duplicate：检查重复元素

参数：

input：输入数组

calculateExpression：计算类型

targetValue：目标值（用于判断操作）

trueReturnValue：真值返回值

falseReturnValue：假值返回值

输出：计算结果

10. AGGREGATE_DATA - 汇总数据

将多个数组按索引位置汇总成字符串。

参数：

arrayList：数组列表

join：连接符

输出：汇总后的字符串

11. ARRAY_REPLACE - 数组替换

对数组中的字符串元素进行批量替换。

参数：

input：输入数组

replaceMap：替换映射Map

输出：替换后的数组

12. ARRAY_CHUNK - 数组切片

将数组按指定大小分割成多个子数组。

参数：

input：输入数组

chunkSize：每片大小

输出：包含分片数组和元信息的Map

使用方法

示例1：数组转文本

{
  "type": "ARRAY_TO_TEXT",
  "input": ["张三", "李四", "王五"],
  "join": ";"
}

输出："张三;李四;王五"

示例2：数组合并

{
  "type": "ARRAY_MERGE",
  "baseArray": ["A", "B"],
  "supplementArray": ["C", "D"],
  "mergePosition": "end"
}

输出：{"result": ["A", "B", "C", "D"]}

示例3：创建对象数组

{
  "type": "CREATE_OBJECT_ARRAY",
  "input": {
    "name": ["张三", "李四"],
    "age": [25, 30],
    "city": ["北京"]
  }
}

输出：

{
  "result": [
    {"name": "张三", "age": 25, "city": "北京"},
    {"name": "李四", "age": 30, "city": null}
  ]
}

示例4：数组求和

{
  "type": "ARRAY_CALCULATE",
  "input": [1, 2, 3, 4, 5],
  "calculateExpression": "sum"
}

输出：15

示例5：判断包含字符串

{
  "type": "ARRAY_CALCULATE",
  "input": ["苹果", "香蕉", "橙子"],
  "calculateExpression": "contains_string",
  "targetValue": "香蕉",
  "trueReturnValue": "找到",
  "falseReturnValue": "未找到"
}

输出："找到"

示例6：数组切片

{
  "type": "ARRAY_CHUNK",
  "input": [1, 2, 3, 4, 5, 6, 7],
  "chunkSize": 3
}

输出：

{
  "chunked_array": [[1, 2, 3], [4, 5, 6], [7]],
  "total_chunks": 3,
  "original_length": 7,
  "meta": {
    "chunk_size": 3,
    "timestamp": 1703123456789
  }
}

示例7：嵌套聚合

{
  "type": "NESTED_AGGREGATE",
  "input": [
    {"user": {"name": "张三", "scores": [85, 90]}},
    {"user": {"name": "李四", "scores": [88, 92]}}
  ],
  "aggregatePathMap": {
    "names": "user.name",
    "first_scores": "user.scores[0]"
  }
}

输出：

{
  "names": ["张三", "李四"],
  "first_scores": [85, 88]
}

高级功能

路径表达式支持

在嵌套聚合中支持复杂的路径表达式：

点分隔：user.name

数组索引：scores[0]

混合使用：user.scores[1]

批量处理

结合循环节点处理多组数组数据：

Loop (遍历数据组)
├── ArrayAction (处理每组数组)
└── VarAction (收集处理结果)

条件处理

根据数组内容进行条件判断：

ArrayAction (数组计算)
├── Condition (检查计算结果)
│   ├── Branch1: 满足条件
│   └── Branch2: 不满足条件

性能优化

流式处理

使用Java Stream API处理大数据集

避免创建不必要的中间集合

支持并行流处理

内存管理

大数组分块处理

及时清理临时变量

避免内存溢出

最佳实践

1. 选择合适的操作类型

数组转换：使用ARRAYTOTEXT或CREATEOBJECTARRAY

数据查询：使用GETBYINDEX或ARRAY_CALCULATE

数据重组：使用ARRAYMERGE或ARRAYCHUNK

2. 参数配置优化

设置合理的chunkSize避免过小分片

使用有意义的join分隔符

验证数组索引范围

3. 错误处理

检查数组是否为空

验证索引范围

处理类型转换异常

4. 性能监控

监控数组处理耗时

统计操作成功率

分析内存使用情况

常见问题

Q: 如何处理嵌套对象数组？

A: 使用NESTED_AGGREGATE操作类型，通过aggregatePathMap指定要提取的字段路径。路径支持点分隔和数组索引，如"user.name"或"scores[0]"。

Q: 数组计算支持哪些数据类型？

A: 支持数值类型（int、long、float、double）和字符串。对于非数值类型，会尝试转换为double，转换失败返回0.0。

Q: 如何处理大数组的性能问题？

A: 使用ARRAY_CHUNK将大数组分割成小块处理，或结合循环节点分批处理。同时注意设置合理的chunkSize，避免内存溢出。

Q: 数组替换只对字符串有效吗？

A: 是的，ARRAY_REPLACE操作只对数组中的字符串元素进行替换。非字符串元素保持不变。

Q: 如何创建不规则的对象数组？

A: 使用CREATEOBJECTARRAY时，不同字段的数组长度可以不同。较短的数组会用null填充到最长数组的长度。

Q: 支持多维数组处理吗？

A: 支持，但需要使用嵌套操作。例如，先使用NESTED_AGGREGATE提取子数组，然后对子数组进行进一步处理。

概述#

功能特性#

支持的操作类型#

1. ARRAYTOTEXT - 数组转文本#

2. ARRAY_MERGE - 数组合并#

3. CREATEOBJECTARRAY - 创建对象数组#

4. CREATEKEYVALUE_PAIRS - 创建键值对数组#

5. TEXTTOARRAY - 文本转数组#

6. GETBYINDEX - 按索引查询#

7. INSERT_ELEMENT - 插入元素#

8. NESTED_AGGREGATE - 嵌套聚合#

9. ARRAY_CALCULATE - 数组计算#

10. AGGREGATE_DATA - 汇总数据#

11. ARRAY_REPLACE - 数组替换#

12. ARRAY_CHUNK - 数组切片#

使用方法#

示例1：数组转文本#

示例2：数组合并#

示例3：创建对象数组#

示例4：数组求和#

示例5：判断包含字符串#

示例6：数组切片#

示例7：嵌套聚合#

高级功能#

路径表达式支持#

批量处理#

条件处理#

性能优化#

流式处理#

内存管理#

最佳实践#

1. 选择合适的操作类型#

2. 参数配置优化#

3. 错误处理#

4. 性能监控#

常见问题#

Q: 如何处理嵌套对象数组？#

Q: 数组计算支持哪些数据类型？#

Q: 如何处理大数组的性能问题？#

Q: 数组替换只对字符串有效吗？#

Q: 如何创建不规则的对象数组？#

Q: 支持多维数组处理吗？#

概述

功能特性

支持的操作类型

1. ARRAYTOTEXT - 数组转文本

2. ARRAY_MERGE - 数组合并

3. CREATEOBJECTARRAY - 创建对象数组

4. CREATEKEYVALUE_PAIRS - 创建键值对数组

5. TEXTTOARRAY - 文本转数组

6. GETBYINDEX - 按索引查询

7. INSERT_ELEMENT - 插入元素

8. NESTED_AGGREGATE - 嵌套聚合

9. ARRAY_CALCULATE - 数组计算

10. AGGREGATE_DATA - 汇总数据

11. ARRAY_REPLACE - 数组替换

12. ARRAY_CHUNK - 数组切片

使用方法

示例1：数组转文本

示例2：数组合并

示例3：创建对象数组

示例4：数组求和

示例5：判断包含字符串

示例6：数组切片

示例7：嵌套聚合

高级功能

路径表达式支持

批量处理

条件处理

性能优化

流式处理

内存管理

最佳实践

1. 选择合适的操作类型

2. 参数配置优化

3. 错误处理

4. 性能监控

常见问题

Q: 如何处理嵌套对象数组？

Q: 数组计算支持哪些数据类型？

Q: 如何处理大数组的性能问题？

Q: 数组替换只对字符串有效吗？

Q: 如何创建不规则的对象数组？

Q: 支持多维数组处理吗？