Time Bin Aggregation Node

Data/DataFusion/Aggregation

Time Bin Aggregation

Create time-based aggregations using DataFusion's date_bin function. Groups data by fixed time intervals (minute, hour, day, etc.) and applies aggregation functions.

df_time_bin_aggregationdata

Inputs10

Outputs5

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.

1/10High

GovernancePolicy, audit, or compliance impact.

2/10High

ReliabilityOperational stability considerations.

2/10High

CostExternal or compute cost impact.

1/10High

Input Pins

Input

Execution

exec_in

Trigger execution

Session

Struct

session

DataFusion session to execute the query in

Source Table

String

source_table

Name of the table to aggregate

Timestamp Column

String

timestamp_column

Column containing timestamp/datetime values

Interval

String

interval

Time interval for binning: second, minute, 5m, 15m, 30m, hour, day, week, month, quarter, year

Default hour

Value Columns

String

value_columns

Columns to aggregate (comma-separated)

Aggregations

String

aggregations

Aggregation functions to apply (comma-separated): count, sum, avg, min, max, first, last

Default count,sum,avg

Group By

String

group_by

Additional columns to group by (comma-separated, optional)

Filter

String

filter

Optional WHERE clause filter (e.g., 'status = active')

Output Table

String

output_table

Name for the result table (optional, creates view if provided)

Output Pins

Output

Execution

exec_out

Continues after query execution

Session

Struct

session_out

DataFusion session (pass-through)

Results

Struct Array

results

Query results as array of row structs

SQL

String

sql

Generated SQL query for debugging

Row Count

Integer

row_count

Number of result rows

Node Info

Internal name: df_time_bin_aggregation
Category: Data/DataFusion/Aggregation
Version: 1