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,102 @@
+version: 2
+
+x-common-fields:
+  - &ntd_id
+    name: ntd_id
+    description: '{{ doc("ntd_id") }}'
+  - &agency
+    name: agency
+    description: '{{ doc("ntd_agency") }}'
+  - &ntd_legacy_id
+    name: ntd_legacy_id
+    description: '{{ doc("ntd_legacy_id") }}'
+  - &report_year
+    name: report_year
+    description: '{{ doc("ntd_report_year") }}'
+  - &reporter_type
+    name: reporter_type
+    description: '{{ doc("ntd_reporter_type") }}'
+  - &organization_type
+    name: organization_type
+    description: '{{ doc("ntd_organization_type") }}'
+  - &city
+    name: city
+    description: '{{ doc("ntd_city") }}'
+  - &state
+    name: state
+    description: '{{ doc("ntd_state") }}'
+  - &primary_uza_code
+    name: primary_uza_code
+    description: '{{ doc("ntd_primary_uza_code") }}'
+  - &primary_uza_name
+    name: primary_uza_name
+    description: '{{ doc("ntd_primary_uza_name") }}'
+  - &primary_uza_area_sq_miles
+    name: primary_uza_area_sq_miles
+    description: '{{ doc("ntd_primary_uza_area_sq_miles") }}'
+  - &primary_uza_population
+    name: primary_uza_population
+    description: '{{ doc("ntd_primary_uza_population") }}'
+  - &service_area_population
+    name: service_area_population
+    description: '{{ doc("ntd_service_area_population") }}'
+  - &service_area_sq_miles
+    name: service_area_sq_miles
+    description: '{{ doc("ntd_service_area_sq_miles") }}'
+  - &type_of_service
+    name: type_of_service
+    description: '{{ doc("ntd_type_of_service") }}'
+  - &mode
+    name: mode
+    description: '{{ doc("ntd_mode") }}'
+  - &mode_name
+    name: mode_name
+    description: '{{ doc("ntd_mode_name") }}'
+  - &time_period
+    name: time_period
+    description: '{{ doc("ntd_time_period") }}'
+  - &questionable_data
+    name: questionable_data
+    description: '{{ doc("ntd_questionable_data") }}'
+  - &agency_voms
+    name: agency_voms
+    description: '{{ doc("ntd_agency_voms") }}'
+  - &actual_vehicle_hours
+    name: actual_vehicle_hours
+    description: '{{ doc("ntd_actual_vehicle_hours") }}'
+
+models:
+  - 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__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__vehicles_age_distribution
+  - name: fct_ntd_annual_data__vehicles_type_count_by_agency
+  - name: fct_ntd_annual_data__service_by_mode_and_time_period
+  - name: fct_ntd_annual_data__service_by_mode
+  - name: fct_ntd_annual_data__service_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__track_and_roadway_by_agency
+  - name: fct_ntd_annual_data__metrics
+  - 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_taxes_levied_by_agency
+  - name: fct_ntd_annual_data__funding_sources_local
+  - name: fct_ntd_annual_data__funding_sources_state
+  - name: fct_ntd_annual_data__funding_sources_federal
+  - name: fct_ntd_annual_data__maintenance_facilities
+  - name: fct_ntd_annual_data__maintenance_facilities_by_agency
+  - name: fct_ntd_annual_data__fuel_and_energy
+  - name: fct_ntd_annual_data__fuel_and_energy_by_agency
+  - name: fct_ntd_annual_data__employees_by_mode_and_employee_type
+  - name: fct_ntd_annual_data__employees_by_mode
+  - name: fct_ntd_annual_data__employees_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__breakdowns
+  - name: fct_ntd_annual_data__breakdowns_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