Trait SinkRender 

pub(crate) trait SinkRender<'scope> {
    // 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: VecCollection<'scope, Timestamp, Row, Diff>,
        err_collection: VecCollection<'scope, Timestamp, DataflowErrorSer, Diff>,
        output_probe: &Handle<Timestamp>,
    ) -> Option<Rc<dyn Any>>;
}

A type that can be rendered as a dataflow sink.

Required Methods

fn render_sink( &self, compute_state: &mut ComputeState, sink: &ComputeSinkDesc<CollectionMetadata>, sink_id: GlobalId, as_of: Antichain<Timestamp>, start_signal: StartSignal, sinked_collection: VecCollection<'scope, Timestamp, Row, Diff>, err_collection: VecCollection<'scope, Timestamp, DataflowErrorSer, Diff>, output_probe: &Handle<Timestamp>, ) -> Option<Rc<dyn Any>>

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl<'scope> SinkRender<'scope> for CopyToS3OneshotSinkConnection

fn render_sink( &self, compute_state: &mut ComputeState, sink: &ComputeSinkDesc<CollectionMetadata>, sink_id: GlobalId, _as_of: Antichain<Timestamp>, _start_signal: StartSignal, sinked_collection: VecCollection<'scope, Timestamp, Row, Diff>, err_collection: VecCollection<'scope, Timestamp, DataflowErrorSer, Diff>, output_probe: &Handle<Timestamp>, ) -> Option<Rc<dyn Any>>

impl<'scope> SinkRender<'scope> for MaterializedViewSinkConnection<CollectionMetadata>

fn render_sink( &self, compute_state: &mut ComputeState, sink: &ComputeSinkDesc<CollectionMetadata>, sink_id: GlobalId, as_of: Antichain<Timestamp>, start_signal: StartSignal, ok_collection: VecCollection<'scope, Timestamp, Row, Diff>, err_collection: VecCollection<'scope, Timestamp, DataflowErrorSer, Diff>, output_probe: &Handle<Timestamp>, ) -> Option<Rc<dyn Any>>

impl<'scope> SinkRender<'scope> for SubscribeSinkConnection

fn render_sink( &self, compute_state: &mut ComputeState, sink: &ComputeSinkDesc<CollectionMetadata>, sink_id: GlobalId, as_of: Antichain<Timestamp>, _start_signal: StartSignal, sinked_collection: VecCollection<'scope, Timestamp, Row, Diff>, err_collection: VecCollection<'scope, Timestamp, DataflowErrorSer, Diff>, output_probe: &Handle<Timestamp>, ) -> Option<Rc<dyn Any>>

Implementors