|
pub async fn history(&self, limit: Option<usize>) -> Result<Vec<CommitInfo>, DeltaTableError> { |
|
let infos = self |
|
.snapshot()? |
|
.snapshot |
|
.snapshot() |
|
.commit_infos(&self.log_store(), limit) |
|
.await? |
|
.try_collect::<Vec<_>>() |
|
.await?; |
|
Ok(infos.into_iter().flatten().collect()) |
|
} |
Since the history commits are yielded in reverse chronological order it would be beneficial for use-cases where we want to break early and not scan lots of small .json files from object store
We can also work with a time filter to just get commits since a given timestamp - I can open a separate issue for this if it sounds reasonable
delta-rs/crates/core/src/table/mod.rs
Lines 232 to 242 in 80d3bb9
Since the history commits are yielded in reverse chronological order it would be beneficial for use-cases where we want to break early and not scan lots of small .json files from object store
We can also work with a time filter to just get commits since a given timestamp - I can open a separate issue for this if it sounds reasonable