time_stream.aggregation.AggregationPipeline

class time_stream.aggregation.AggregationPipeline(agg_func, ctx, aggregation_period, columns, missing_criteria=None)

Abstract base class for aggregation pipelines.

Subclasses implement the grouping strategy (standard period grouping or rolling window) while sharing the common execute() template and helper expressions.

Use StandardAggregationPipeline for fixed-period aggregation and RollingAggregationPipeline for sliding-window aggregation.

Parameters:

• agg_func (AggregationFunction)

• ctx (AggregationCtx)

• aggregation_period (Period)

• columns (str | list[str])

• missing_criteria (tuple[Literal['percent', 'missing', 'available', 'na'], float | int] | None)

__init__(agg_func, ctx, aggregation_period, columns, missing_criteria=None)

Parameters:

• agg_func (AggregationFunction)

• ctx (AggregationCtx)

• aggregation_period (Period)

• columns (str | list[str])

• missing_criteria (tuple[Literal['percent', 'missing', 'available', 'na'], float | int] | None)

Methods

__init__(agg_func, ctx, aggregation_period, ...)
execute()	Run the aggregation pipeline.