Skip to main content

remap_timely_event_ids

Function remap_timely_event_ids 

Source
fn remap_timely_event_ids(event: &mut TimelyEvent)
Expand description

Remaps operator, channel, and address IDs in a TimelyEvent so that events forwarded to compute’s logging dataflow don’t collide with compute’s IDs.