Trait mz_storage::render::sinks::SinkRender

pub(crate) trait SinkRender<G>
where
    G: Scope<Timestamp = Timestamp>,
{
    // Required methods
    fn get_key_indices(&self) -> Option<&[usize]>;
    fn get_relation_key_indices(&self) -> Option<&[usize]>;
    fn render_sink(
        &self,
        storage_state: &mut StorageState,
        sink: &StorageSinkDesc<MetadataFilled, Timestamp>,
        sink_id: GlobalId,
        sinked_collection: Collection<G, (Option<Row>, DiffPair<Row>), Diff>,
        err_collection: Collection<G, DataflowError, Diff>,
    ) -> (Stream<G, HealthStatusMessage>, Vec<PressOnDropButton>);
}

A type that can be rendered as a dataflow sink.

Required Methods

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

Gets the indexes of the columns that form the key that the user specified when creating the sink, if any.

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

Gets the indexes of the columns that form a key of the sink’s underlying relation, if such a key exists.

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

Renders the sink’s dataflow.

Implementations on Foreign Types

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

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

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

fn render_sink( &self, storage_state: &mut StorageState, sink: &StorageSinkDesc<MetadataFilled, Timestamp>, sink_id: GlobalId, input: Collection<G, (Option<Row>, DiffPair<Row>), Diff>, _err_collection: Collection<G, DataflowError, Diff>, ) -> (Stream<G, HealthStatusMessage>, Vec<PressOnDropButton>)

Implementors