Struct UpdateBuilder

pub struct UpdateBuilder { /* private fields */ }

Updates records in the Delta Table. See this module’s documentation for more information

Implementations

impl UpdateBuilder

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

Create a new [‘UpdateBuilder’]

pub fn with_predicate<E: Into<Expression>>(self, predicate: E) -> Self

Which records to update

pub fn with_update<S: Into<DeltaColumn>, E: Into<Expression>>( self, column: S, expression: E, ) -> Self

Perform an additional update expression during the operaton

pub fn with_session_state(self, state: SessionState) -> Self

The Datafusion session state to use

pub fn with_commit_properties(self, commit_properties: CommitProperties) -> Self

Additional metadata to be added to commit info

pub fn with_writer_properties(self, writer_properties: WriterProperties) -> Self

Writer properties passed to parquet writer for when fiiles are rewritten

pub fn with_safe_cast(self, safe_cast: bool) -> Self

Specify the cast options to use when casting columns that do not match the table’s schema. When cast_options.safe is set true then any failures to cast a datatype will use null instead of returning an error to the user.

Example (column’s type is int): Input Output 123 -> 123 Test123 -> null

Trait Implementations

impl IntoFuture for UpdateBuilder

type Output = Result<(DeltaTable, UpdateMetrics), DeltaTableError>

The output that the future will produce on completion.

type IntoFuture = Pin<Box<dyn Future<Output = <UpdateBuilder as IntoFuture>::Output> + Send>>

Which kind of future are we turning this into?

fn into_future(self) -> Self::IntoFuture

Creates a future from a value.