pub struct DiskANNBuildInput { /* private fields */ }Expand description
Repeatable encrypted input, with fixed-width navigation and numeric-side records. Dense navigation IDs follow canonical logical order without a resident global directory.
Implementations§
Source§impl DiskANNBuildInput
impl DiskANNBuildInput
Sourcepub fn write_generation(
&self,
graph: &DiskANNMergedGraph,
options: DiskANNGenerationOptions,
sink: &mut dyn DiskANNBuildSink,
) -> StorageBackendResult<DiskANNManifest>
pub fn write_generation( &self, graph: &DiskANNMergedGraph, options: DiskANNGenerationOptions, sink: &mut dyn DiskANNBuildSink, ) -> StorageBackendResult<DiskANNManifest>
Stream immutable records to the selected private generation. The returned manifest must pass the sink owner’s physical seal before opening; it grants no SQL/MVCC publication authority.
Source§impl DiskANNBuildInput
impl DiskANNBuildInput
Sourcepub fn merge_partitions(
&self,
partitions: DiskANNPartitionRuns,
directory: &Path,
options: DiskANNMergeOptions,
) -> StorageBackendResult<DiskANNMergedGraph>
pub fn merge_partitions( &self, partitions: DiskANNPartitionRuns, directory: &Path, options: DiskANNMergeOptions, ) -> StorageBackendResult<DiskANNMergedGraph>
Consume partition candidates, externally order them, and prune using full navigation vectors. Capture and candidates must share source coverage and both resource allowances.
Source§impl DiskANNBuildInput
impl DiskANNBuildInput
Sourcepub fn build_partitions(
&self,
directory: &Path,
parameters: DiskANNIndexParams,
options: DiskANNPartitionOptions,
) -> StorageBackendResult<DiskANNPartitionRuns>
pub fn build_partitions( &self, directory: &Path, parameters: DiskANNIndexParams, options: DiskANNPartitionOptions, ) -> StorageBackendResult<DiskANNPartitionRuns>
Construct one admitted Vamana graph at a time. All temporary runs share the capture’s existing disk allowance, and all buffers retain its original memory/cancellation control.
Source§impl DiskANNBuildInput
impl DiskANNBuildInput
Sourcepub fn capture_source(
generation: DiskANNGeneration,
source: &dyn DiskANNCanonicalRead,
directory: &Path,
temporary: &DiskANNTemporaryBudget,
control: &StorageReadControl,
) -> StorageBackendResult<Self>
pub fn capture_source( generation: DiskANNGeneration, source: &dyn DiskANNCanonicalRead, directory: &Path, temporary: &DiskANNTemporaryBudget, control: &StorageReadControl, ) -> StorageBackendResult<Self>
Capture a retained provider source without fabricating mutation origins or collecting its corpus. The resulting fingerprint is still not a visibility token or publication authority.
Sourcepub fn capture(
generation: DiskANNGeneration,
dimensions: u32,
directory: &Path,
temporary: &DiskANNTemporaryBudget,
control: &StorageReadControl,
read: impl FnOnce(&mut DiskANNBuildVisitor<'_>) -> StorageBackendResult<()>,
) -> StorageBackendResult<Self>
pub fn capture( generation: DiskANNGeneration, dimensions: u32, directory: &Path, temporary: &DiskANNTemporaryBudget, control: &StorageReadControl, read: impl FnOnce(&mut DiskANNBuildVisitor<'_>) -> StorageBackendResult<()>, ) -> StorageBackendResult<Self>
Enumerate every selected canonical ordinal once in document order. Any source or consumer failure discards the entire capture, including failures the source suppresses; temporary data is never a staged or published generation.
pub fn dimensions(&self) -> u32
pub fn node_count(&self) -> u64
pub fn side_count(&self) -> u64
pub fn coverage(&self) -> DiskANNBuildCoverage
pub fn read_node(&self, node: u64) -> StorageBackendResult<DiskANNBuildVector>
pub fn read_side(&self, index: u64) -> StorageBackendResult<DiskANNBuildVector>
Sourcepub fn train(
&self,
pq_bytes: usize,
options: PQTrainingOptions,
) -> StorageBackendResult<Option<PQCodebook>>
pub fn train( &self, pq_bytes: usize, options: PQTrainingOptions, ) -> StorageBackendResult<Option<PQCodebook>>
Train the existing bounded reservoir by replaying captured navigation values. Empty and all-side inputs have no codebook; invalid settings still fail validation.