httk.store.backend.sql.bulk_deferred

Stage-side finalization for fresh SQL bulk ingests.

Unlike httk.store.backend.sql.bulk_parallel’s parity merger this module never loads provisional rows into a record table. It builds temporary maps over the external stage, computes the reachable canonical rows, and projects each real table exactly once with final dense sids.

Classes

DeferredFinalizer

Set-wise, non-destructive finalizer for one empty-store ingest.

Module Contents

class httk.store.backend.sql.bulk_deferred.DeferredFinalizer(ingest, manifests)

Set-wise, non-destructive finalizer for one empty-store ingest.

ingest
store
connection
manifests
graph
parents
stage_views: dict[str, str]
maps: dict[str, str]
finals: dict[str, str]
objects: list[str] = []
finalize_timings: dict[str, float]
root_stage: str | None = None
root_occurrences: str | None = None
run()
cleanup()

Drop every main-database temporary relation before marker clear.