Struct Snapshot

pub struct Snapshot { /* private fields */ }

A snapshot of a Delta table

Implementations

impl Snapshot

pub async fn try_new( table_root: &Path, store: Arc<dyn ObjectStore>, config: DeltaTableConfig, version: Option<i64>, ) -> DeltaResult<Self>

Create a new Snapshot instance

pub async fn update( &mut self, log_store: Arc<dyn LogStore>, target_version: Option<i64>, ) -> DeltaResult<()>

Update the snapshot to the given version

pub fn version(&self) -> i64

Get the table version of the snapshot

pub fn schema(&self) -> &StructType

Get the table schema of the snapshot

pub fn metadata(&self) -> &Metadata

Get the table metadata of the snapshot

pub fn protocol(&self) -> &Protocol

Get the table protocol of the snapshot

pub fn load_config(&self) -> &DeltaTableConfig

Get the table config which is loaded with of the snapshot

pub fn table_root(&self) -> Path

Get the table root of the snapshot

pub fn table_config(&self) -> TableConfig<'_>

Well known table configuration

pub fn files<'a>( &self, store: Arc<dyn ObjectStore>, visitors: &'a mut Vec<Box<dyn ReplayVisitor>>, ) -> DeltaResult<ReplayStream<'a, BoxStream<'_, DeltaResult<RecordBatch>>>>

Get the files in the snapshot

pub fn stats_schema( &self, table_schema: Option<&StructType>, ) -> DeltaResult<StructType>

Get the statistics schema of the snapshot

pub fn partitions_schema( &self, table_schema: Option<&StructType>, ) -> DeltaResult<Option<StructType>>

Get the partition values schema of the snapshot

Trait Implementations

impl Clone for Snapshot

fn clone(&self) -> Snapshot

Returns a copy of the value.

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

Performs copy-assignment from source.

impl DataFusionMixins for Snapshot

fn arrow_schema(&self) -> DeltaResult<ArrowSchemaRef>

The physical datafusion schema of a table

fn input_schema(&self) -> DeltaResult<ArrowSchemaRef>

Get the table schema as an ArrowSchemaRef

fn parse_predicate_expression( &self, expr: impl AsRef<str>, df_state: &SessionState, ) -> DeltaResult<Expr>

Parse an expression string into a datafusion Expr

impl Debug for Snapshot

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Snapshot

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for Snapshot

fn eq(&self, other: &Snapshot) -> 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 Serialize for Snapshot

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 Snapshot