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.