stupidb.aggregator

Base aggregator interface.

Classes

Aggregate(*args, **kwds)

An aggregate or window function.

Aggregator(arguments, cls)

Interface for aggregators.

class stupidb.aggregator.Aggregate(*args, **kwds)[source]

An aggregate or window function.

classmethod prepare(possible_peers, getters, order_by_columns)[source]

Prepare an aggregation of this type for computation.

class stupidb.aggregator.Aggregator(arguments, cls)[source]

Interface for aggregators.

Aggregators must implement the query() method. Aggregators are tied to a specific kind of aggregation. See the prepare() method for how to provide a custom aggregator.

abstract query(begin, end)[source]

Query the aggregator over the range from begin to end.