mirror of
https://github.com/DOI-DO/j40-cejst-2.git
synced 2025-02-23 18:14:19 -08:00
placeholder etl files
This commit is contained in:
parent
f284d75098
commit
d4d72c8830
3 changed files with 38 additions and 0 deletions
|
@ -0,0 +1,38 @@
|
||||||
|
import geopandas as gpd
|
||||||
|
import numpy as np
|
||||||
|
import pandas as pd
|
||||||
|
from data_pipeline.etl.base import ExtractTransformLoad, ValidGeoLevel
|
||||||
|
from data_pipeline.etl.sources.geo_utils import (
|
||||||
|
add_tracts_for_geometries,
|
||||||
|
get_tribal_geojson,
|
||||||
|
get_tract_geojson,
|
||||||
|
)
|
||||||
|
from data_pipeline.score import field_names
|
||||||
|
from data_pipeline.utils import get_module_logger
|
||||||
|
|
||||||
|
logger = get_module_logger(__name__)
|
||||||
|
|
||||||
|
|
||||||
|
class GeoCorrAlternativesETL(ExtractTransformLoad):
|
||||||
|
"""Calculates overlap between Census tracts & various alternative geographies."""
|
||||||
|
|
||||||
|
# Metadata for the baseclass
|
||||||
|
NAME = "geocorr_alternatives"
|
||||||
|
GEO_LEVEL = ValidGeoLevel.CENSUS_TRACT
|
||||||
|
|
||||||
|
# Define these for easy code completion
|
||||||
|
def __init__(self):
|
||||||
|
self.COLUMNS_TO_KEEP = [
|
||||||
|
self.GEOID_TRACT_FIELD_NAME,
|
||||||
|
]
|
||||||
|
|
||||||
|
self.output_df: pd.DataFrame
|
||||||
|
|
||||||
|
def extract(self) -> None:
|
||||||
|
pass
|
||||||
|
|
||||||
|
def transform(self) -> None:
|
||||||
|
logger.info("Starting GeoCorr alternatives transforms.")
|
||||||
|
|
||||||
|
# self.output_df =
|
||||||
|
|
Loading…
Add table
Reference in a new issue