Trait mz_compute::render::sinks::SinkRender

pub(crate) trait SinkRender<G>where
    G: Scope<Timestamp = Timestamp>,{
    // Required method
    fn render_continuous_sink(
        &self,
        compute_state: &mut ComputeState,
        sink: &ComputeSinkDesc<CollectionMetadata>,
        sink_id: GlobalId,
        as_of: Antichain<Timestamp>,
        sinked_collection: Collection<G, Row, Diff>,
        err_collection: Collection<G, DataflowError, Diff>
    ) -> Option<Rc<dyn Any>>
       where G: Scope<Timestamp = Timestamp>;
}

A type that can be rendered as a dataflow sink.

Required Methods

fn render_continuous_sink( &self, compute_state: &mut ComputeState, sink: &ComputeSinkDesc<CollectionMetadata>, sink_id: GlobalId, as_of: Antichain<Timestamp>, sinked_collection: Collection<G, Row, Diff>, err_collection: Collection<G, DataflowError, Diff> ) -> Option<Rc<dyn Any>>where G: Scope<Timestamp = Timestamp>,

Implementations on Foreign Types

impl<G> SinkRender<G> for CopyToS3OneshotSinkConnectionwhere G: Scope<Timestamp = Timestamp>,

fn render_continuous_sink( &self, compute_state: &mut ComputeState, sink: &ComputeSinkDesc<CollectionMetadata>, sink_id: GlobalId, _as_of: Antichain<Timestamp>, sinked_collection: Collection<G, Row, Diff>, err_collection: Collection<G, DataflowError, Diff> ) -> Option<Rc<dyn Any>>where G: Scope<Timestamp = Timestamp>,

impl<G> SinkRender<G> for PersistSinkConnection<CollectionMetadata>where G: Scope<Timestamp = Timestamp>,

fn render_continuous_sink( &self, compute_state: &mut ComputeState, sink: &ComputeSinkDesc<CollectionMetadata>, sink_id: GlobalId, as_of: Antichain<Timestamp>, sinked_collection: Collection<G, Row, Diff>, err_collection: Collection<G, DataflowError, Diff> ) -> Option<Rc<dyn Any>>where G: Scope<Timestamp = Timestamp>,

impl<G> SinkRender<G> for SubscribeSinkConnectionwhere G: Scope<Timestamp = Timestamp>,

fn render_continuous_sink( &self, compute_state: &mut ComputeState, sink: &ComputeSinkDesc<CollectionMetadata>, sink_id: GlobalId, as_of: Antichain<Timestamp>, sinked_collection: Collection<G, Row, Diff>, err_collection: Collection<G, DataflowError, Diff> ) -> Option<Rc<dyn Any>>where G: Scope<Timestamp = Timestamp>,

Implementors