Trait mz_storage::render::sinks::SinkRender

pub(crate) trait SinkRender<G>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,
        storage_state: &mut StorageState,
        sink: &StorageSinkDesc<MetadataFilled, Timestamp>,
        sink_id: GlobalId,
        sinked_collection: Collection<G, (Option<Row>, Option<Row>), Diff>,
        err_collection: Collection<G, DataflowError, Diff>
    ) -> (Stream<G, HealthStatusMessage>, Vec<PressOnDropButton>)
       where G: Scope<Timestamp = Timestamp>;
}

A type that can be rendered as a dataflow sink.

Required Methods

fn uses_keys(&self) -> bool

TODO

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

TODO

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

TODO

fn render_continuous_sink( &self, storage_state: &mut StorageState, sink: &StorageSinkDesc<MetadataFilled, Timestamp>, sink_id: GlobalId, sinked_collection: Collection<G, (Option<Row>, Option<Row>), Diff>, err_collection: Collection<G, DataflowError, Diff> ) -> (Stream<G, HealthStatusMessage>, Vec<PressOnDropButton>)where G: Scope<Timestamp = Timestamp>,

TODO

Implementations on Foreign Types

impl<G: Scope<Timestamp = Timestamp>> SinkRender<G> for KafkaSinkConnection

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, storage_state: &mut StorageState, sink: &StorageSinkDesc<MetadataFilled, Timestamp>, sink_id: GlobalId, input: Collection<G, (Option<Row>, Option<Row>), Diff>, _err_collection: Collection<G, DataflowError, Diff> ) -> (Stream<G, HealthStatusMessage>, Vec<PressOnDropButton>)

Implementors