Crate fermentation

An implementation of Forward Decay to enable various aggregations over stream of items. See the research paper for more details on forward decay.

Modules

aggregate

Aggregate computations on streams of items using a forward decay model.

g

Various implementations of positive monotone non-decreasing functions, used to calculate the decayed weight of an item.

space_saving

An implementation of the SpaceSaving algorithm. The algorithm is adjusted according to support the forward decay model.

Structs

ForwardDecay

The forward decay is computed on the amount of time between the arrival of an item and a fixed point L, known as the landmark. By convention, this landmark is some time earlier than all other items; we discuss how this landmark can be chosen below. Thus, we are looking forward in time from the landmark to see the item, instead of looking backward from the current time.

Traits

Item

An item in a stream of inputs.