Struct CdcScan

pub struct CdcScan {
    pub table_name: String,
    pub output_col_idx: Vec<usize>,
    pub cdc_table_desc: Rc<CdcTableDesc>,
    pub ctx: OptimizerContextRef,
    pub options: CdcScanOptions,
}

CdcScan reads rows of a table from an external upstream database

Fields

table_name: String

output_col_idx: Vec<usize>

Include output_col_idx and columns required in predicate

cdc_table_desc: Rc<CdcTableDesc>

Descriptor of the external table for CDC

ctx: OptimizerContextRef

options: CdcScanOptions

Implementations

impl CdcScan

pub fn rewrite_exprs(&self, _rewriter: &mut dyn ExprRewriter)

pub fn visit_exprs(&self, _v: &mut dyn ExprVisitor)

pub fn output_column_ids(&self) -> Vec<ColumnId>

Get the ids of the output columns.

pub fn primary_key(&self) -> &[ColumnOrder]

pub fn watermark_columns(&self) -> WatermarkColumns

pub fn columns_monotonicity(&self) -> MonotonicityMap

pub(crate) fn column_names_with_table_prefix(&self) -> Vec<String>

pub(crate) fn column_names(&self) -> Vec<String>

pub fn i2o_col_mapping(&self) -> ColIndexMapping

get the Mapping of columnIndex from internal column index to output column index

pub fn output_and_pk_column_ids(&self) -> Vec<ColumnId>

Get the ids of the output columns and primary key columns.

pub(crate) fn new( table_name: String, output_col_idx: Vec<usize>, cdc_table_desc: Rc<CdcTableDesc>, ctx: OptimizerContextRef, options: CdcScanOptions, ) -> Self

Create a logical scan node for CDC backfill

pub(crate) fn columns_pretty<'a>(&self, verbose: bool) -> Pretty<'a>

impl CdcScan

pub fn get_table_columns(&self) -> &[ColumnDesc]

pub fn append_only(&self) -> bool

pub fn column_descs(&self) -> Vec<ColumnDesc>

Get the descs of the output columns.

Trait Implementations

impl Clone for CdcScan

fn clone(&self) -> CdcScan

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CdcScan

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl From<CdcScan> for LogicalCdcScan

fn from(core: CdcScan) -> Self

Converts to this type from the input type.

impl From<CdcScan> for PlanRef

fn from(core: CdcScan) -> Self

Converts to this type from the input type.

impl GenericPlanNode for CdcScan

fn schema(&self) -> Schema

fn stream_key(&self) -> Option<Vec<usize>>

fn ctx(&self) -> OptimizerContextRef

fn functional_dependency(&self) -> FunctionalDependencySet

impl Hash for CdcScan

where String: Hash, Vec<usize>: Hash, Rc<CdcTableDesc>: Hash, CdcScanOptions: Hash,

fn hash<H: Hasher>(&self, state: &mut H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for CdcScan

where String: PartialEq, Vec<usize>: PartialEq, Rc<CdcTableDesc>: PartialEq, CdcScanOptions: PartialEq,

fn eq(&self, other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for CdcScan

where String: PartialEq, Vec<usize>: PartialEq, Rc<CdcTableDesc>: PartialEq, CdcScanOptions: PartialEq,