rust/lancedb
1
0
Fork 0
mirror of https://github.com/lancedb/lancedb.git synced 2026-05-15 11:00:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: fast path for checkout_latest (#1355)

Browse Source 
similar to https://github.com/lancedb/lancedb/pull/1354
do locked IO less frequently
This commit is contained in:
Rob Meng
2024-06-04 23:01:28 -04:00
committed by GitHub
parent ddceda4ff7
commit d39e7d23f4
1 changed files with 14 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
rust/lancedb/src/table/dataset.rs
View File

@@ -66,6 +66,10 @@ impl DatasetRef {
Ok(())
}
fn is_latest(&self) -> bool {
matches!(self, Self::Latest { .. })
}
async fn need_reload(&self) -> Result<bool> {
Ok(match self {
Self::Latest { dataset, .. } => {
@@ -172,11 +176,16 @@ impl DatasetConsistencyWrapper {
/// Convert into a wrapper in latest version mode
pub async fn as_latest(&self, read_consistency_interval: Option<Duration>) -> Result<()> {
self.0
.write()
.await
.as_latest(read_consistency_interval)
.await
if self.0.read().await.is_latest() {
return Ok(());
}
let mut write_guard = self.0.write().await;
if write_guard.is_latest() {
return Ok(());
}
write_guard.as_latest(read_consistency_interval).await
}
pub async fn as_time_travel(&self, target_version: u64) -> Result<()> {