risingwave_stream::executor::backfill::cdc::upstream_table::snapshot

Trait UpstreamTableRead

Source 
pub trait UpstreamTableRead {
    // Required methods
    fn snapshot_read_full_table(
        &self,
        args: SnapshotReadArgs,
        batch_size: u32,
    ) -> impl Stream<Item = StreamExecutorResult<Option<StreamChunk>>> + Send + '_;
    fn current_cdc_offset(
        &self,
    ) -> impl Future<Output = StreamExecutorResult<Option<CdcOffset>>> + Send + '_;
}

Required Methods§

Source

fn snapshot_read_full_table( &self, args: SnapshotReadArgs, batch_size: u32, ) -> impl Stream<Item = StreamExecutorResult<Option<StreamChunk>>> + Send + '_

Source

fn current_cdc_offset( &self, ) -> impl Future<Output = StreamExecutorResult<Option<CdcOffset>>> + Send + '_

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§