Function dataflow::source::maybe_emit_timestamp_bindings [−][src]
fn maybe_emit_timestamp_bindings(
source_name: &str,
worker_id: usize,
timestamp_bindings_updater: &mut Option<TimestampBindingUpdater>,
timestamp_histories: &mut TimestampBindingRc,
bindings_cap: &Capability<u64>,
bindings_output: &mut OutputHandle<'_, u64, ((SourceTimestamp, AssignedTimestamp), u64, isize), Tee<u64, ((SourceTimestamp, AssignedTimestamp), u64, isize)>>
)
Expand description
Updates the given timestamp_bindings_updater
with any changes from the given
timestamp_histories
and emits updates to bindings_output
if there are in fact any changes.
The updates emitted from this can be used to re-construct the state of a TimestampBindingRc
at any given time by reading and applying (and consolidating, if neccessary) the stream of
changes.