risingwave_connector::source::cdc::external

Trait ExternalTableReader

source 
pub trait ExternalTableReader {
    // Required methods
    async fn current_cdc_offset(&self) -> ConnectorResult<CdcOffset>;
    fn snapshot_read(
        &self,
        table_name: SchemaTableName,
        start_pk: Option<OwnedRow>,
        primary_keys: Vec<String>,
        limit: u32,
    ) -> BoxStream<'_, ConnectorResult<OwnedRow>>;
}

Required Methods§

source

async fn current_cdc_offset(&self) -> ConnectorResult<CdcOffset>

source

fn snapshot_read( &self, table_name: SchemaTableName, start_pk: Option<OwnedRow>, primary_keys: Vec<String>, limit: u32, ) -> BoxStream<'_, ConnectorResult<OwnedRow>>

Object Safety§

This trait is not object safe.

Implementors§