Struct CdfLoadBuilder

pub struct CdfLoadBuilder { /* private fields */ }

Builder for create a read of change data feeds for delta tables

Implementations

impl CdfLoadBuilder

pub fn new(log_store: LogStoreRef, snapshot: DeltaTableState) -> Self

Create a new [LoadBuilder]

pub fn with_starting_version(self, starting_version: i64) -> Self

Version to start at (version 0 if not provided)

pub fn with_ending_version(self, ending_version: i64) -> Self

Version (inclusive) to end at

pub fn with_session_ctx(self, ctx: SessionContext) -> Self

Provide a datafusion session context

pub fn with_ending_timestamp(self, timestamp: DateTime<Utc>) -> Self

Timestamp (inclusive) to end at

pub fn with_starting_timestamp(self, timestamp: DateTime<Utc>) -> Self

Timestamp to start from

pub fn with_columns(self, columns: Vec<String>) -> Self

Columns to select

pub async fn build(&self) -> DeltaResult<DeltaCdfScan>

Executes the scan

Trait Implementations

impl Clone for CdfLoadBuilder

fn clone(&self) -> CdfLoadBuilder

Returns a copy of the value.

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

Performs copy-assignment from source.