From 9a34f92b21df333ace43f9de25b95a50954a8402 Mon Sep 17 00:00:00 2001 From: Xuanwo Date: Fri, 21 Aug 2026 17:58:14 +0800 Subject: [PATCH] refactor: expose fragment publication API --- rust/lancedb/src/_internal.rs | 14 -------------- rust/lancedb/src/lib.rs | 2 -- rust/lancedb/src/table.rs | 2 +- rust/lancedb/src/table/fragment_publication.rs | 9 ++++----- 4 files changed, 5 insertions(+), 22 deletions(-) delete mode 100644 rust/lancedb/src/_internal.rs diff --git a/rust/lancedb/src/_internal.rs b/rust/lancedb/src/_internal.rs deleted file mode 100644 index 887e507a4..000000000 --- a/rust/lancedb/src/_internal.rs +++ /dev/null @@ -1,14 +0,0 @@ -// SPDX-License-Identifier: Apache-2.0 -// SPDX-FileCopyrightText: Copyright The LanceDB Authors - -//! Unstable integration contracts used by LanceDB Enterprise components. -//! -//! Nothing in this module is a supported SDK surface. Types and functions may -//! change without a semver-major release. - -pub mod fragment_publication { - pub use crate::table::fragment_publication::{ - CommitOutcome, CommitReceipt, FragmentInputBinding, FragmentOutputBinding, - FragmentPublicationBasis, FragmentPublicationOptions, FragmentPublisher, - }; -} diff --git a/rust/lancedb/src/lib.rs b/rust/lancedb/src/lib.rs index b010ee8ab..291dcaf65 100644 --- a/rust/lancedb/src/lib.rs +++ b/rust/lancedb/src/lib.rs @@ -172,8 +172,6 @@ // auto-traits (`Send`) through the Linux io_uring build's moka cache. Raise it. #![recursion_limit = "256"] -#[doc(hidden)] -pub mod _internal; pub mod arrow; pub mod blob; pub mod connection; diff --git a/rust/lancedb/src/table.rs b/rust/lancedb/src/table.rs index 1aad7c81a..37544a55a 100644 --- a/rust/lancedb/src/table.rs +++ b/rust/lancedb/src/table.rs @@ -73,7 +73,7 @@ mod create_index; pub mod datafusion; pub(crate) mod dataset; pub mod delete; -pub(crate) mod fragment_publication; +pub mod fragment_publication; pub mod lsm_stats; pub mod merge; pub mod optimize; diff --git a/rust/lancedb/src/table/fragment_publication.rs b/rust/lancedb/src/table/fragment_publication.rs index 6dee4cdf1..75daac7f9 100644 --- a/rust/lancedb/src/table/fragment_publication.rs +++ b/rust/lancedb/src/table/fragment_publication.rs @@ -3,10 +3,9 @@ //! One-fragment publication for registered Function columns. //! -//! This is an internal Enterprise integration boundary. It publishes one -//! complete, physical-row-aligned sibling group with one `DataReplacement` -//! transaction. Planning, execution, retry, and multi-fragment aggregation -//! remain outside this module. +//! This module publishes one complete, physical-row-aligned sibling group with +//! one `DataReplacement` transaction. Planning, execution, retry, and +//! multi-fragment aggregation remain outside this module. use std::collections::{BTreeSet, HashMap}; use std::sync::Arc; @@ -196,7 +195,7 @@ pub struct CommitReceipt { pub commit_outcome: CommitOutcome, } -/// Internal one-fragment Function-column publisher. +/// One-fragment Function-column publisher. #[derive(Debug, Clone)] pub struct FragmentPublisher { table: Table,