Trait dataflow::render::sinks::SinkRender

pub trait SinkRender<G> where
    G: Scope<Timestamp = Timestamp>, {
    fn uses_keys(&self) -> bool;
    fn get_key_indices(&self) -> Option<&[usize]>;
    fn get_relation_key_indices(&self) -> Option<&[usize]>;
    fn render_continuous_sink(
        &self, 
        compute_state: &mut ComputeState, 
        sink: &SinkDesc, 
        sink_id: GlobalId, 
        sinked_collection: Collection<G, (Option<Row>, Option<Row>), Diff>, 
        metrics: &SinkBaseMetrics
    ) -> Option<Rc<dyn Any>>
    where
        G: Scope<Timestamp = Timestamp>;
}

Required methods

fn uses_keys(&self) -> bool

fn get_key_indices(&self) -> Option<&[usize]>

fn get_relation_key_indices(&self) -> Option<&[usize]>

fn render_continuous_sink(
    &self,
    compute_state: &mut ComputeState,
    sink: &SinkDesc,
    sink_id: GlobalId,
    sinked_collection: Collection<G, (Option<Row>, Option<Row>), Diff>,
    metrics: &SinkBaseMetrics
) -> Option<Rc<dyn Any>> where
    G: Scope<Timestamp = Timestamp>, 

Implementations on Foreign Types

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

fn uses_keys(&self) -> bool

fn get_key_indices(&self) -> Option<&[usize]>

fn get_relation_key_indices(&self) -> Option<&[usize]>

fn render_continuous_sink(
    &self,
    _compute_state: &mut ComputeState,
    _sink: &SinkDesc,
    sink_id: GlobalId,
    sinked_collection: Collection<G, (Option<Row>, Option<Row>), Diff>,
    _metrics: &SinkBaseMetrics
) -> Option<Rc<dyn Any>> where
    G: Scope<Timestamp = Timestamp>, 

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

fn uses_keys(&self) -> bool

fn get_key_indices(&self) -> Option<&[usize]>

fn get_relation_key_indices(&self) -> Option<&[usize]>

fn render_continuous_sink(
    &self,
    compute_state: &mut ComputeState,
    sink: &SinkDesc,
    sink_id: GlobalId,
    sinked_collection: Collection<G, (Option<Row>, Option<Row>), Diff>,
    metrics: &SinkBaseMetrics
) -> Option<Rc<dyn Any>> where
    G: Scope<Timestamp = Timestamp>, 

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

fn uses_keys(&self) -> bool

fn get_key_indices(&self) -> Option<&[usize]>

fn get_relation_key_indices(&self) -> Option<&[usize]>

fn render_continuous_sink(
    &self,
    compute_state: &mut ComputeState,
    sink: &SinkDesc,
    sink_id: GlobalId,
    sinked_collection: Collection<G, (Option<Row>, Option<Row>), Diff>,
    _metrics: &SinkBaseMetrics
) -> Option<Rc<dyn Any>> where
    G: Scope<Timestamp = Timestamp>, 

Implementors