etlplus.ops.transformations.aggregate

etlplus.ops.transformations.aggregate module.

Aggregate helpers shared by etlplus.ops.transform and custom runners.

Use apply_aggregate() for a single aggregate spec that returns one mapping. Use apply_aggregate_step() when you need the one-row list shape consumed by etlplus.ops.transform.transform().

Functions

apply_aggregate(records, operation)	Aggregate a numeric field or count presence.
apply_aggregate_step(rows, spec)	Apply a single aggregate pipeline step and return a one-row result list.