Struct deltalake::checkpoints::CheckPointWriter

pub struct CheckPointWriter { /* fields omitted */ }

Struct for writing checkpoints to the delta log.

Implementations

impl CheckPointWriter

pub fn new(table_uri: &str, storage: Box<dyn StorageBackend>) -> Self

Creates a new CheckPointWriter.

pub fn new_for_table_uri(table_uri: &str) -> Result<Self, CheckPointWriterError>

Creates a new CheckPointWriter for the table URI.

pub async fn create_checkpoint_for_version(
    &self,
    version: DeltaDataTypeVersion
) -> Result<(), CheckPointWriterError>

Creates a new checkpoint at the specified version. NOTE: This method loads a new instance of delta table to determine the state to checkpoint.

pub async fn create_checkpoint_from_state(
    &self,
    version: DeltaDataTypeVersion,
    state: &DeltaTableState
) -> Result<(), CheckPointWriterError>

Creates a new checkpoint at the specified version from the given DeltaTableState.