Function mz_compute::sink::materialized_view_v2::mint::render

source ยท 
pub fn render<S>(
    sink_id: GlobalId,
    persist_api: PersistApi,
    as_of: Antichain<Timestamp>,
    active_worker_id: usize,
    read_only_rx: Receiver<bool>,
    desired: &OkErr<Stream<S, (Row, Timestamp, Diff)>, Stream<S, (DataflowError, Timestamp, Diff)>>,
) -> (OkErr<Stream<S, (Row, Timestamp, Diff)>, Stream<S, (DataflowError, Timestamp, Diff)>>, Stream<S, BatchDescription>, Rc<RefCell<Antichain<Timestamp>>>, PressOnDropButton)
where
    S: Scope<Timestamp = Timestamp>,
Expand description

Render the mint operator.

The parameters passed in are:

  • sink_id: The GlobalId of the sink export.
  • persist_api: An object providing access to the output persist shard.
  • as_of: The first time for which the sink may produce output.
  • active_worker_id: The ID of the worker that runs this (single-threaded) operator.
  • read_only_tx: A receiver that reports the sink is in read-only mode.
  • desired: The ok/err streams that should be sinked to persist.