Enum SyncMode 

pub enum SyncMode {
    Full,
    Incremental,
    Cdc,
}

Variants

Full

Re-read the whole table when its snapshot changes (idempotent MERGE).

Incremental

Read only what changed since the last processed snapshot. Over Spark Connect it is an EXCEPT ALL diff — append-only, inserts alone. Over an Iceberg table read by skade (watch) it is the same per-commit changelog as SyncMode::Cdc: updates and deletes are applied too.

Cdc

Changelog (CDC) mode: read Iceberg’s system.create_changelog_view between the last and the current snapshot, exposing a _change_type column (INSERT / UPDATE_AFTER / UPDATE_BEFORE / DELETE). INSERT/UPDATE_AFTER rows become upserts; DELETE rows become DETACH DELETEs. UPDATE_BEFORE (the update pre-image) is dropped — its UPDATE_AFTER upsert already carries the new state. The first round (no prior snapshot) reads the whole table as inserts, like Full.

Implementations

impl SyncMode

pub const CHANGE_TYPE_COLUMN: &'static str = "_change_type"

The sentinel column the Iceberg changelog view adds in Cdc mode, and that the listener partitions on before stripping it from values.

Trait Implementations

impl Clone for SyncMode

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for SyncMode

impl Debug for SyncMode

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

Formats the value using the given formatter.

impl Default for SyncMode

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for SyncMode

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for SyncMode

impl PartialEq for SyncMode

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for SyncMode

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for SyncMode