Skip to contents

All functions

lnk_aggregate()
Compute upstream habitat per crossing
lnk_barrier_overrides()
Build barrier override list from evidence sources
lnk_barriers_emit()
Emit slim crossings_lookup + per-source barriers_* tables
lnk_barriers_unify()
Unify per-WSG barrier sources into the working-schema <schema>.barriers
lnk_barriers_views()
Create working-schema views over <persist_schema>.barriers
lnk_baseline_append()
Append a row to the run-tracking baseline ledger
lnk_baseline_current()
Is this host's baseline already current at the supplied upstream?
lnk_baseline_read()
Read the run-tracking baseline ledger
lnk_bucket_get()
Download a single artifact from a public S3 bucket prefix
lnk_bucket_log()
Read the build-identifier log.json from a bucket prefix
lnk_compare_rollup()
Compare one watershed group's persisted state against a reference
lnk_compare_wsg()
Compare one watershed group against a reference dataset
lnk_config()
Load a Pipeline Config Bundle (Manifest)
lnk_config_verify()
Verify Config Bundle File Checksums and Shape
lnk_db_conn()
Connect to FWA PostgreSQL database
lnk_inputs_verify()
Verify that required Postgres tables exist in a connection
lnk_load()
Load override CSVs into a database table
lnk_load_overrides()
Materialize the Tabular Data Files Declared in a Config Bundle
lnk_mapping_code()
Build per-segment per-species mapping_code tokens from schema tables
lnk_match()
Match crossing records across data systems
lnk_override()
Validate and apply overrides to a table
lnk_parity_annotate()
Annotate a parity rollup against the bcfp divergence taxonomy
lnk_persist_init()
Initialize persistent province-wide habitat tables
lnk_pipeline_access()
Build per-segment access codes + downstream-feature arrays
lnk_pipeline_break()
Segment the Stream Network at Configured Break Positions
lnk_pipeline_classify()
Classify Stream Segments into Habitat per Species
lnk_pipeline_connect()
Apply Rearing-Spawning and Waterbody Connectivity
lnk_pipeline_crossings()
Build crossings + barriers_* tables from primitives
lnk_pipeline_load()
Load Crossings and Apply Crossing-Level Overrides
lnk_pipeline_mapping_code()
Build per-segment per-species mapping_code strings (bcfp parity)
lnk_pipeline_persist()
Persist per-WSG output into the province-wide habitat tables
lnk_pipeline_prepare()
Prepare the Network and Barrier Inputs for a Pipeline Run
lnk_pipeline_run()
Run the link pipeline end-to-end for one watershed group
lnk_pipeline_setup()
Set Up the Working Schema for a Pipeline Run
lnk_pipeline_species()
Resolve the Species Set for an AOI
lnk_points_snap()
Snap a Postgres table of points to the FWA stream network
lnk_presence()
Per-AOI species presence with bcfp species-group expansion
lnk_rules_build()
Build habitat eligibility rules YAML from dimensions CSV
lnk_score()
Score crossings
lnk_source()
Produce a fresh-compatible break source list
lnk_stamp()
Capture a Pipeline Run Stamp
lnk_stamp_finish()
Finalize an in-progress run stamp
lnk_thresholds()
Load configurable severity scoring thresholds