Module differential_dataflow::consolidation

Common logic for the consolidation of vectors of Semigroups.

Often we find ourselves with collections of records with associated weights (often integers) where we want to reduce the collection to the point that each record occurs at most once, with the accumulated weights. These methods supply that functionality.

Importantly, these methods are used internally by differential dataflow, but are made public for the convenience of others. Their precise behavior is driven by the needs of differential dataflow (chiefly: canonicalizing sequences of non-zero updates); should you need specific behavior, it may be best to defensively copy, paste, and maintain the specific behavior you require.

Structs

• ConsolidatingContainerBuilder
  A container builder that consolidates data in-places into fixed-sized containers. Does not maintain FIFO ordering.

Traits

• ConsolidateLayout
  Layout of containers and their read items to be consolidated.

Functions

• consolidate
  Sorts and consolidates vec.
• consolidate_from
  Sorts and consolidate vec[offset..].
• consolidate_slice
  Sorts and consolidates a slice, returning the valid prefix length.
• consolidate_updates
  Sorts and consolidates vec.
• consolidate_updates_from
  Sorts and consolidate vec[offset..].
• consolidate_updates_slice
  Sorts and consolidates a slice, returning the valid prefix length.