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>>

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§