ARRAY_REDUCE

命令格式

R array_reduce(array<T> <a>, buf <init>, function<buf, T, buf> <merge>, function<buf, R> <final>)

参数说明

• a：必填。ARRAY数组。array<T>中的T指代ARRAY数组元素的数据类型，数组中的元素可以为任意类型。

• init：必填。用于聚合的中间结果的初始值。

• merge：必填。将ARRAY数组a中的每一个元素与中间结果进行运算的函数（内建函数或自定义函数）或表达式。它的两个输入参数为ARRAY数组a的元素和init。

• final：必填。将中间结果转换为最终结果的函数（内建函数或自定义函数）或表达式。它的输入参数为merge运行结果，R指代输出结果的数据类型。

返回值说明

返回结果类型与final函数定义的输出结果类型一致。

使用示例

--返回6。
select array_reduce(array(1, 2, 3), 0, (buf, e)->buf + e, buf->buf);
--返回2.5。
select array_reduce(array(1, 2, 3, 4), named_struct('sum', 0, 'count', 0), (buf, e)->named_struct('sum', buf.sum + e, 'count', buf.count + 1), buf -> buf.sum / buf.count);

相关函数

• ARRAY_REDUCE函数属于复杂类型函数，更多对复杂类型数据（例如ARRAY、MAP、STRUCT、JSON数据）的处理函数请参见复杂类型函数。

• ARRAY_REDUCE函数使用示例中涉及->的使用，关于Lambda函数->的介绍，详情请参见Lambda函数。