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.