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 + '_

Object Safety§

This trait is not object safe.

Implementors§