Skip to main content

run_load

Function run_load 

Source
pub fn run_load(
    loader: &dyn TargetLoader,
    table: &str,
    specs: &[TargetColumnSpec],
    uris: &[String],
    expected_rows: Option<u64>,
    cleanup: Option<(&GcsStore, &str)>,
) -> Result<LoadReport>
Expand description

Batch load driver. Materialize table from uris, gate the landed rows against expected_rows (the reconciled file count; None skips the gate), and — only after the gate passes — clean up the source via cleanup (Some((store, gs_prefix)) to delete, None to keep it).

#[allow(private_interfaces)] for the injected GcsStore — same rationale as reconcile::fetch_manifests_keyed: a pub public-API root over a deliberately crate-private destination type.