阿里云首页 工业大脑开放平台

窗口聚合

本文为您介绍数据处理组件中的窗口聚合组件。

功能说明

窗口聚合组件可以根据指定的索引列,将相同索引的数据根据时间列进行聚合。在需要将某一段时间内的数据聚合时,可以使用窗口聚合组件。聚合的方法包括:均值,最大值,最小值,中位数。若窗口内无数值,聚合后会产生空值。

计算逻辑原理

  • 均值:取分组窗口聚合中的均值。

  • 最大值:取分组窗口聚合中的最大值。

  • 最小值:取分组窗口聚合中的最小值。

  • 中位数:取分组窗口聚合中的中位数(若数据总数为偶数,中位数取中间两个值的平均值)。

参数说明

IN端口

参数名

参数描述

是否必填

输入数据类型

数据源类型

索引列

按照索引列进行分组聚合。

不限

  • csv组件

  • igateoffline组件

  • 平台上其他数据处理组件

  • 按照平台组件开发的自定义组件

数据列

需要窗口聚合处理的数据列。

整数或浮点数

说明

若存在非数值数据,则会置为NaN

  • csv组件

  • igateoffline组件

  • 平台上其他数据处理组件

  • 按照平台组件开发的自定义组件

时间列

窗口处理的时间列。

时间或字符

说明

若存在非时间数据,则会抛出异常

  • csv组件

  • igateoffline组件

  • 平台上其他数据处理组件

  • 按照平台组件开发的自定义组件

OUT端口

参数名

参数描述

是否必填

输出数据类型

输出

输出参数包含索引列、数据列和时间列中的输入参数。

索引列:与输入数据类型一致

数据列:浮点数

时间列:字符

其他参数

参数名

参数描述

是否必填

参数默认值

参数范围

聚合方法

选择窗口聚合的方法。

均值

  • 均值

  • 最大值

  • 最小值

  • 中位数

窗口时长

聚合的窗口时长,单位:秒。

60

[0, 99999999]