expose all ntd annual reporting staging tables as mart

warehouse/dbt_project.yml

@@ -69,3 +69,5 @@ models:
         schema: mart_benefits
       ntd_validation:
         schema: mart_ntd_validation
+      ntd_fct_annual:
+        schema: mart_ntd_fct_annual

warehouse/models/mart/ntd_fct_annual/_mart_ntd_fct_annual.yml

@@ -0,0 +1,37 @@
+version: 2
+
+models:
+  - name: fct_ntd_annual_data__breakdowns
+  - name: fct_ntd_annual_data__breakdowns_by_agency
+  - name: fct_ntd_annual_data__capital_expenses_by_capital_use
+  - name: fct_ntd_annual_data__capital_expenses_by_mode
+  - name: fct_ntd_annual_data__capital_expenses_for_existing_service
+  - name: fct_ntd_annual_data__capital_expenses_for_expansion_of_service
+  - name: fct_ntd_annual_data__employees_by_agency
+  - name: fct_ntd_annual_data__employees_by_mode
+  - name: fct_ntd_annual_data__employees_by_mode_and_employee_type
+  - name: fct_ntd_annual_data__fuel_and_energy
+  - name: fct_ntd_annual_data__fuel_and_energy_by_agency
+  - name: fct_ntd_annual_data__funding_sources_by_expense_type
+  - name: fct_ntd_annual_data__funding_sources_directly_generated
+  - name: fct_ntd_annual_data__funding_sources_federal
+  - name: fct_ntd_annual_data__funding_sources_local
+  - name: fct_ntd_annual_data__funding_sources_state
+  - name: fct_ntd_annual_data__funding_sources_taxes_levied_by_agency
+  - name: fct_ntd_annual_data__maintenance_facilities
+  - name: fct_ntd_annual_data__maintenance_facilities_by_agency
+  - name: fct_ntd_annual_data__metrics
+  - name: fct_ntd_annual_data__operating_expenses_by_function
+  - name: fct_ntd_annual_data__operating_expenses_by_function_and_agency
+  - name: fct_ntd_annual_data__operating_expenses_by_type
+  - name: fct_ntd_annual_data__operating_expenses_by_type_and_agency
+  - name: fct_ntd_annual_data__service_by_agency
+  - name: fct_ntd_annual_data__service_by_mode
+  - name: fct_ntd_annual_data__service_by_mode_and_time_period
+  - name: fct_ntd_annual_data__stations_and_facilities_by_agency_and_facility_type
+  - name: fct_ntd_annual_data__stations_by_mode_and_age
+  - name: fct_ntd_annual_data__track_and_roadway_by_agency
+  - name: fct_ntd_annual_data__track_and_roadway_by_mode
+  - name: fct_ntd_annual_data__track_and_roadway_guideway_age_distribution
+  - name: fct_ntd_annual_data__vehicles_age_distribution
+  - name: fct_ntd_annual_data__vehicles_type_count_by_agency

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__breakdowns.sql

@@ -0,0 +1,11 @@
+WITH staging_breakdowns AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__breakdowns') }}
+),
+
+fct_ntd_annual_data__breakdowns AS (
+    SELECT *
+    FROM staging_breakdowns
+)
+
+SELECT * FROM fct_ntd_annual_data__breakdowns

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__breakdowns_by_agency.sql

@@ -0,0 +1,11 @@
+WITH staging_breakdowns_by_agency AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__breakdowns_by_agency') }}
+),
+
+fct_ntd_annual_data__breakdowns_by_agency AS (
+    SELECT *
+    FROM staging_breakdowns_by_agency
+)
+
+SELECT * FROM fct_ntd_annual_data__breakdowns_by_agency

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__capital_expenses_by_capital_use.sql

@@ -0,0 +1,11 @@
+WITH staging_capital_expenses_by_capital_use AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__capital_expenses_by_capital_use') }}
+),
+
+fct_ntd_annual_data__capital_expenses_by_capital_use AS (
+    SELECT *
+    FROM staging_capital_expenses_by_capital_use
+)
+
+SELECT * FROM fct_ntd_annual_data__capital_expenses_by_capital_use

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__capital_expenses_by_mode.sql

@@ -0,0 +1,11 @@
+WITH staging_capital_expenses_by_mode AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__capital_expenses_by_mode') }}
+),
+
+fct_ntd_annual_data__capital_expenses_by_mode AS (
+    SELECT *
+    FROM staging_capital_expenses_by_mode
+)
+
+SELECT * FROM fct_ntd_annual_data__capital_expenses_by_mode

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__capital_expenses_for_existing_service.sql

@@ -0,0 +1,11 @@
+WITH staging_capital_expenses_for_existing_service AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__capital_expenses_for_existing_service') }}
+),
+
+fct_ntd_annual_data__capital_expenses_for_existing_service AS (
+    SELECT *
+    FROM staging_capital_expenses_for_existing_service
+)
+
+SELECT * FROM fct_ntd_annual_data__capital_expenses_for_existing_service

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__capital_expenses_for_expansion_of_service.sql

@@ -0,0 +1,11 @@
+WITH staging_capital_expenses_for_expansion_of_service AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__capital_expenses_for_expansion_of_service') }}
+),
+
+fct_ntd_annual_data__capital_expenses_for_expansion_of_service AS (
+    SELECT *
+    FROM staging_capital_expenses_for_expansion_of_service
+)
+
+SELECT * FROM fct_ntd_annual_data__capital_expenses_for_expansion_of_service

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__employees_by_agency.sql

@@ -0,0 +1,11 @@
+WITH staging_employees_by_agency AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__employees_by_agency') }}
+),
+
+fct_ntd_annual_data__employees_by_agency AS (
+    SELECT *
+    FROM staging_employees_by_agency
+)
+
+SELECT * FROM fct_ntd_annual_data__employees_by_agency

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__employees_by_mode.sql

@@ -0,0 +1,11 @@
+WITH staging_employees_by_mode AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__employees_by_mode') }}
+),
+
+fct_ntd_annual_data__employees_by_mode AS (
+    SELECT *
+    FROM staging_employees_by_mode
+)
+
+SELECT * FROM fct_ntd_annual_data__employees_by_mode

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__employees_by_mode_and_employee_type.sql

@@ -0,0 +1,11 @@
+WITH staging_employees_by_mode_and_employee_type AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__employees_by_mode_and_employee_type') }}
+),
+
+fct_ntd_annual_data__employees_by_mode_and_employee_type AS (
+    SELECT *
+    FROM staging_employees_by_mode_and_employee_type
+)
+
+SELECT * FROM fct_ntd_annual_data__employees_by_mode_and_employee_type

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__fuel_and_energy.sql

@@ -0,0 +1,11 @@
+WITH staging_fuel_and_energy AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__fuel_and_energy') }}
+),
+
+fct_ntd_annual_data__fuel_and_energy AS (
+    SELECT *
+    FROM staging_fuel_and_energy
+)
+
+SELECT * FROM fct_ntd_annual_data__fuel_and_energy

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__fuel_and_energy_by_agency.sql

@@ -0,0 +1,11 @@
+WITH staging_fuel_and_energy_by_agency AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__fuel_and_energy_by_agency') }}
+),
+
+fct_ntd_annual_data__fuel_and_energy_by_agency AS (
+    SELECT *
+    FROM staging_fuel_and_energy_by_agency
+)
+
+SELECT * FROM fct_ntd_annual_data__fuel_and_energy_by_agency

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__funding_sources_by_expense_type.sql

@@ -0,0 +1,11 @@
+WITH staging_funding_sources_by_expense_type AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__funding_sources_by_expense_type') }}
+),
+
+fct_ntd_annual_data__funding_sources_by_expense_type AS (
+    SELECT *
+    FROM staging_funding_sources_by_expense_type
+)
+
+SELECT * FROM fct_ntd_annual_data__funding_sources_by_expense_type

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__funding_sources_directly_generated.sql

@@ -0,0 +1,11 @@
+WITH staging_funding_sources_directly_generated AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__funding_sources_directly_generated') }}
+),
+
+fct_ntd_annual_data__funding_sources_directly_generated AS (
+    SELECT *
+    FROM staging_funding_sources_directly_generated
+)
+
+SELECT * FROM fct_ntd_annual_data__funding_sources_directly_generated

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__funding_sources_federal.sql

@@ -0,0 +1,11 @@
+WITH staging_funding_sources_federal AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__funding_sources_federal') }}
+),
+
+fct_ntd_annual_data__funding_sources_federal AS (
+    SELECT *
+    FROM staging_funding_sources_federal
+)
+
+SELECT * FROM fct_ntd_annual_data__funding_sources_federal

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__funding_sources_local.sql

@@ -0,0 +1,11 @@
+WITH staging_funding_sources_local AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__funding_sources_local') }}
+),
+
+fct_ntd_annual_data__funding_sources_local AS (
+    SELECT *
+    FROM staging_funding_sources_local
+)
+
+SELECT * FROM fct_ntd_annual_data__funding_sources_local

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__funding_sources_state.sql

@@ -0,0 +1,11 @@
+WITH staging_funding_sources_state AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__funding_sources_state') }}
+),
+
+fct_ntd_annual_data__funding_sources_state AS (
+    SELECT *
+    FROM staging_funding_sources_state
+)
+
+SELECT * FROM fct_ntd_annual_data__funding_sources_state

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__funding_sources_taxes_levied_by_agency.sql

@@ -0,0 +1,11 @@
+WITH staging_funding_sources_taxes_levied_by_agency AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__funding_sources_taxes_levied_by_agency') }}
+),
+
+fct_ntd_annual_data__funding_sources_taxes_levied_by_agency AS (
+    SELECT *
+    FROM staging_funding_sources_taxes_levied_by_agency
+)
+
+SELECT * FROM fct_ntd_annual_data__funding_sources_taxes_levied_by_agency

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__maintenance_facilities.sql

@@ -0,0 +1,11 @@
+WITH staging_maintenance_facilities AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__maintenance_facilities') }}
+),
+
+fct_ntd_annual_data__maintenance_facilities AS (
+    SELECT *
+    FROM staging_maintenance_facilities
+)
+
+SELECT * FROM fct_ntd_annual_data__maintenance_facilities

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__maintenance_facilities_by_agency.sql

@@ -0,0 +1,11 @@
+WITH staging_maintenance_facilities_by_agency AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__maintenance_facilities_by_agency') }}
+),
+
+fct_ntd_annual_data__maintenance_facilities_by_agency AS (
+    SELECT *
+    FROM staging_maintenance_facilities_by_agency
+)
+
+SELECT * FROM fct_ntd_annual_data__maintenance_facilities_by_agency

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__metrics.sql

@@ -0,0 +1,11 @@
+WITH staging_metrics AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__metrics') }}
+),
+
+fct_ntd_annual_data__metrics AS (
+    SELECT *
+    FROM staging_metrics
+)
+
+SELECT * FROM fct_ntd_annual_data__metrics

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__operating_expenses_by_function.sql

@@ -0,0 +1,11 @@
+WITH staging_operating_expenses_by_function AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__operating_expenses_by_function') }}
+),
+
+fct_ntd_annual_data__operating_expenses_by_function AS (
+    SELECT *
+    FROM staging_operating_expenses_by_function
+)
+
+SELECT * FROM fct_ntd_annual_data__operating_expenses_by_function

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__operating_expenses_by_function_and_agency.sql

@@ -0,0 +1,11 @@
+WITH staging_operating_expenses_by_function_and_agency AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__operating_expenses_by_function_and_agency') }}
+),
+
+fct_ntd_annual_data__operating_expenses_by_function_and_agency AS (
+    SELECT *
+    FROM staging_operating_expenses_by_function_and_agency
+)
+
+SELECT * FROM fct_ntd_annual_data__operating_expenses_by_function_and_agency

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__operating_expenses_by_type.sql

@@ -0,0 +1,11 @@
+WITH staging_operating_expenses_by_type AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__operating_expenses_by_type') }}
+),
+
+fct_ntd_annual_data__operating_expenses_by_type AS (
+    SELECT *
+    FROM staging_operating_expenses_by_type
+)
+
+SELECT * FROM fct_ntd_annual_data__operating_expenses_by_type

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__operating_expenses_by_type_and_agency.sql

@@ -0,0 +1,11 @@
+WITH staging_operating_expenses_by_type_and_agency AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__operating_expenses_by_type_and_agency') }}
+),
+
+fct_ntd_annual_data__operating_expenses_by_type_and_agency AS (
+    SELECT *
+    FROM staging_operating_expenses_by_type_and_agency
+)
+
+SELECT * FROM fct_ntd_annual_data__operating_expenses_by_type_and_agency

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__service_by_agency.sql

@@ -0,0 +1,11 @@
+WITH staging_service_by_agency AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__service_by_agency') }}
+),
+
+fct_ntd_annual_data__service_by_agency AS (
+    SELECT *
+    FROM staging_service_by_agency
+)
+
+SELECT * FROM fct_ntd_annual_data__service_by_agency

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__service_by_mode.sql

@@ -0,0 +1,11 @@
+WITH staging_service_by_mode AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__service_by_mode') }}
+),
+
+fct_ntd_annual_data__service_by_mode AS (
+    SELECT *
+    FROM staging_service_by_mode
+)
+
+SELECT * FROM fct_ntd_annual_data__service_by_mode

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__service_by_mode_and_time_period.sql

@@ -0,0 +1,11 @@
+WITH staging_service_by_mode_and_time_period AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__service_by_mode_and_time_period') }}
+),
+
+fct_ntd_annual_data__service_by_mode_and_time_period AS (
+    SELECT *
+    FROM staging_service_by_mode_and_time_period
+)
+
+SELECT * FROM fct_ntd_annual_data__service_by_mode_and_time_period

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__stations_and_facilities_by_agency_and_facility_type.sql

@@ -0,0 +1,11 @@
+WITH staging_stations_and_facilities_by_agency_and_facility_type AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__stations_and_facilities_by_agency_and_facility_type') }}
+),
+
+fct_ntd_annual_data__stations_and_facilities_by_agency_and_facility_type AS (
+    SELECT *
+    FROM staging_stations_and_facilities_by_agency_and_facility_type
+)
+
+SELECT * FROM fct_ntd_annual_data__stations_and_facilities_by_agency_and_facility_type

warehouse/models/mart/ntd_fct_annual/fct_ntd_annual_data__stations_by_mode_and_age.sql

@@ -0,0 +1,11 @@
+WITH staging_stations_by_mode_and_age AS (
+    SELECT *
+    FROM {{ ref('stg_ntd_annual_data__stations_by_mode_and_age') }}
+),
+
+fct_ntd_annual_data__stations_by_mode_and_age AS (
+    SELECT *
+    FROM staging_stations_by_mode_and_age
+)
+
+SELECT * FROM fct_ntd_annual_data__stations_by_mode_and_age