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 columnarArranged. - 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
PointStampof loop counters.