Module pipelines.rj_cor.meteorologia.precipitacao_alertario.utils

Utils for precipitacao_alertario

Functions

def parse_date_columns(dataframe: pandas.core.frame.DataFrame, partition_date_column: str) ‑> Tuple[pandas.core.frame.DataFrame, List[str]]

Parses the date columns to the partition format. Reformatado para manter o formato utilizado quando os dados foram salvos pela primeira vez (ano, mes, dia).

def parse_date_columns_old_api(dataframe: pandas.core.frame.DataFrame, partition_date_column: str) ‑> Tuple[pandas.core.frame.DataFrame, List[str]]

Parses the date columns to the partition format. Reformatado para manter o formato utilizado quando os dados foram salvos pela primeira vez (ano, mes, dia).

def treat_date_col(row)

Add zero hour if date cames without it