Window Aggregation Node

W

Data/DataFusion/Aggregation

Window Aggregation

Apply window functions for rolling/moving aggregations over time series data.

df_window_aggregationdata

Inputs9

Outputs4

Security exposure2/10

Packagedata

Ratings

Scores range from 0 to 10. Higher values mean more impact, exposure, or operational weight.

SecurityAttack surface and exposure impact.

2/10High

PrivacyPotential sensitivity of processed data.

2/10High

PerformanceRuntime or resource pressure.

2/10High

GovernancePolicy, audit, or compliance impact.

2/10High

ReliabilityOperational stability considerations.

2/10High

CostExternal or compute cost impact.

1/10High

Input Pins

9

Input

Execution

exec_in

Trigger execution

Session

Struct

session

DataFusion session

SchemaDataFusionSessionDataFusionSessionDataFusionSession1 fields

cache_keystringrequired

Source Table

String

source_table

Table to query

Timestamp Column

String

timestamp_column

Column for ordering

Value Column

String

value_column

Column to aggregate

Window Function

String

window_function

Function: avg, sum, min, max, count, row_number, rank, lag, lead

Default avg

Window Size

Integer

window_size

Number of preceding rows (for rolling window), use 0 for cumulative

Default 10

Partition By

String

partition_by

Columns to partition by (comma-separated, optional)

Select Columns

String

select_columns

Additional columns to include (comma-separated)

Default *

Output Pins

4

Output

Execution

exec_out

Execution continues

Session

Struct

session_out

Session pass-through

SchemaDataFusionSessionDataFusionSessionDataFusionSession1 fields

cache_keystringrequired

Results

Struct Array

results

Query results

SQL

String

sql

Generated SQL

Node Info

Internal name

df_window_aggregation

Category

Data/DataFusion/Aggregation

Version

1