Sliding Time Window Aggregator¶
This stage aggregates the data of a single point by the sliding time window. FuThe settings for this stage are as per the below.
- Window type: Sliding window.
- Supported aggregators: max/min/avg/count/sum/first/last.
Configuration¶
The configuration tabs for this stage are General, Basic, and Input/Output.
General¶
Name | Required? | Description |
---|---|---|
Name | Yes | The name of the stage. |
Description | No | The description of the stage. |
Stage Library | Yes | The streaming calculator library to which the stage belongs. |
Required Fields | No | The fields that the data records must contain. If the specified fields are not included, the record will be filtered out. |
Preconditions | No | The conditions that must be satisfied by the data records. Records that do not meet the conditions will be filtered out. |
On Record Error | Yes | The processing method for error data.
|
Basic¶
Name | Required? | Description |
---|---|---|
Quality Filter | No | Filter the data according to the data quality. Only records that meet the quality conditions will be processed by this stage. |
Input/Output¶
Name | Required? | Description |
---|---|---|
Input Point | Yes | Specify the input point of the records, using the format {modelId}::{pointId}. |
Fixed Window Size | Yes | Specify the duration for the fixed time window, which is equal to the step length of the sliding window. |
Fixed Window Unit | Yes | Select the unit for the fixed time window. |
Sliding Window Size | Yes | Specify the step length of the sliding window. |
Sliding Window Unit | Yes | Select the unit for the sliding window. |
Aggregator Policy | Yes | Select the aggregator for data aggregation: max/min/avg/count/sum/first/last. |
Output Point | Yes | Specify the output point of thr records, using the format {modelId}::{pointId}. |
Output Results¶
The output results of this stage are included in the attr
struct. The description of the fields are as follows:
Name | Data Type | Description |
---|---|---|
lastOutput | Integer/Double/Float | The last output of the point (NaN for no output). |
calMode | String | The output mode, which is the final output. |
calType | String | The selected aggregator: max/min/avg/count/sum/first/last. |
calDetail | Map | The calculation details. For example, when calType=avg, output the sum and count value of value and lastValue. |