refactor: expose fragment publication API

This commit is contained in:
Xuanwo
2026-08-21 17:58:14 +08:00
parent 0002bc5844
commit 9a34f92b21
4 changed files with 5 additions and 22 deletions
-14
View File
@@ -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,
};
}
-2
View File
@@ -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;
+1 -1
View File
@@ -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;
@@ -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,