Skip to main content

Module operators

Module operators 

Source
Expand description

Dataflow operators over the columnar RecordedUpdates container — the collection-level surface of the columnar chunk.

join_function is a columnar flat_map (subsuming map/filter/negate/ enter_at); leave_dynamic truncates dynamic-scope timestamps; and as_recorded_updates extracts a RecordedUpdates collection from a columnar arrangement’s batch stream.

Functions§

as_recorded_updates
Extract a Collection<_, RecordedUpdates<U>> from a columnar Arranged.
join_function
A columnar flat_map: iterates RecordedUpdates, calls logic per (key, val, time, diff), joins output times with input times, multiplies output diffs with input diffs.
leave_dynamic
Leave a dynamic iterative scope, truncating PointStamp coordinates.

Type Aliases§

DynTime
Timestamp shape of a dynamic iterative scope: an outer timestamp paired with a per-level PointStamp of loop counters.