Date Truncate Aggregation Node

Data/DataFusion/Aggregation

Date Truncate Aggregation

Truncate timestamps to a specific precision (hour, day, month, etc.) and aggregate. Simpler alternative to date_bin for standard intervals.

df_date_trunc_aggregationdata

Inputs7

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.

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

Source Table

String

source_table

Table to aggregate

Timestamp Column

String

timestamp_column

Timestamp column name

Precision

String

precision

Truncation precision: second, minute, hour, day, week, month, quarter, year

Default hour

Aggregation SQL

String

aggregation_sql

SQL aggregation expressions (e.g., 'COUNT(*) as cnt, SUM(amount) as total')

Filter

String

filter

Optional WHERE clause

Output Pins

Output

Execution

exec_out

Execution continues

Session

Struct

session_out

Session pass-through

Results

Struct Array

results

Aggregation results

SQL

String

sql

Generated SQL

Node Info

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