Skip to content
Flow Like logo Flow Like Docs

Time Bin Aggregation Node

Data/DataFusion/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 exposure8/10
Packagedata

Ratings

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

SecurityAttack surface and exposure impact.
8/10High
PrivacyPotential sensitivity of processed data.
8/10High
PerformanceRuntime or resource pressure.
9/10High
GovernancePolicy, audit, or compliance impact.
8/10High
ReliabilityOperational stability considerations.
8/10High
CostExternal or compute cost impact.
9/10High

Input Pins

10

Input

Execution
exec_in

Trigger execution

Session

Struct
session

DataFusion session to execute the query in

DataFusionSessionDataFusionSession1 fields
cache_keystringrequired

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

5

Output

Execution
exec_out

Continues after query execution

Session

Struct
session_out

DataFusion session (pass-through)

DataFusionSessionDataFusionSession1 fields
cache_keystringrequired

Results

Struct Array
results

Query results as array of row structs

objectobject0 fields
No named fields in this schema.

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