httk.store.db.bulk_deferred

Stage-side finalization for fresh SQL bulk ingests.

Unlike httk.store.db.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.db.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.