Trait mz_compute::render::sinks::SinkRender

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

A type that can be rendered as a dataflow sink.

Required Methods§

source

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

Implementations on Foreign Types§

source§

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

source§

fn render_sink( &self, compute_state: &mut ComputeState, _sink: &ComputeSinkDesc<CollectionMetadata>, sink_id: GlobalId, as_of: Antichain<Timestamp>, start_signal: StartSignal, oks: Collection<G, Row, Diff>, errs: Collection<G, DataflowError, Diff>, append_times: Option<Collection<G, (), Diff>>, ) -> Option<Rc<dyn Any>>

source§

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

source§

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

source§

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

source§

fn render_sink( &self, compute_state: &mut ComputeState, sink: &ComputeSinkDesc<CollectionMetadata>, sink_id: GlobalId, as_of: Antichain<Timestamp>, start_signal: StartSignal, ok_collection: Collection<G, Row, Diff>, err_collection: Collection<G, DataflowError, Diff>, _ct_times: Option<Collection<G, (), Diff>>, ) -> Option<Rc<dyn Any>>

source§

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

source§

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

Implementors§