Aggregate

AggregateOp

Bases: PhysicalOperator

Aggregate operators accept a list of candidate DataRecords as input to their call methods. Thus, we use a slightly modified abstract base class for these operators.

__call__

__call__(candidates: DataRecordSet) -> DataRecordSet

ApplyGroupByOp

Bases: AggregateOp

Implementation of a GroupBy operator. This operator groups records by a set of fields and applies a function to each group. The group_by_sig object contains the fields to group by and the aggregation functions to apply to each group.

__init__

__init__(group_by_sig: GroupBySig, *args, **kwargs)

__call__

__call__(candidates: DataRecordSet) -> DataRecordSet

AverageAggregateOp

Bases: AggregateOp

__init__

__init__(agg_func: AggFunc, *args, **kwargs)

__call__

__call__(candidates: DataRecordSet) -> DataRecordSet

CountAggregateOp

Bases: AggregateOp

__init__

__init__(agg_func: AggFunc, *args, **kwargs)

__call__

__call__(candidates: DataRecordSet) -> DataRecordSet