mz_compute::sink::materialized_view::append

Function render

Source 
pub fn render<S>(
    sink_id: GlobalId,
    persist_api: PersistApi,
    descs: &Stream<S, BatchDescription>,
    batches: &Stream<S, (BatchDescription, ProtoBatch)>,
) -> PressOnDropButton
where
    S: Scope<Timestamp = Timestamp>,
Expand description

Render the append 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.
  • descs: The stream of batch descriptions produced by the mint operator.
  • batches: The stream of written batches produced by the write operator.