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, DataflowError, Diff>,
        ct_times: Option<VecCollection<'scope, Timestamp, (), 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, DataflowError, Diff>, ct_times: Option<VecCollection<'scope, Timestamp, (), Diff>>, output_probe: &Handle<Timestamp>, ) -> Option<Rc<dyn Any>>

Implementations on Foreign Types

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

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

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, DataflowError, Diff>, _ct_times: Option<VecCollection<'scope, Timestamp, (), 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, DataflowError, Diff>, _ct_times: Option<VecCollection<'scope, Timestamp, (), 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, DataflowError, Diff>, _ct_times: Option<VecCollection<'scope, Timestamp, (), Diff>>, output_probe: &Handle<Timestamp>, ) -> Option<Rc<dyn Any>>

Implementors