Index

A

add_silver_metadata() (in module fabrictools) (in module fabrictools.quality) (in module fabrictools.quality.clean), [1]

B

build_dimension_city() (in module fabrictools) (in module fabrictools.dimensions) (in module fabrictools.dimensions.geo) build_dimension_country() (in module fabrictools) (in module fabrictools.dimensions) (in module fabrictools.dimensions.geo) build_dimension_date() (in module fabrictools) (in module fabrictools.dimensions) (in module fabrictools.dimensions.date)

build_lakehouse_read_path_candidates() (in module fabrictools.core) (in module fabrictools.core.paths) build_lakehouse_write_path() (in module fabrictools.core) (in module fabrictools.core.paths) build_table_jobs_from_config() (in module fabrictools.pipelines) (in module fabrictools.pipelines.config) build_table_jobs_from_discovery() (in module fabrictools.pipelines) (in module fabrictools.pipelines.config)

C

cast_columns() (in module fabrictools.transform) clean_and_write_all_tables() (in module fabrictools) (in module fabrictools.quality) (in module fabrictools.quality.pipeline) clean_and_write_data() (in module fabrictools) (in module fabrictools.quality) (in module fabrictools.quality.pipeline)

clean_data() (in module fabrictools) (in module fabrictools.quality) (in module fabrictools.quality.clean), [1] coalesce_dim() (in module fabrictools) (in module fabrictools.transform)

D

dataframe_last_nonnull_wide_month_from_long() (in module fabrictools) (in module fabrictools.transform) dataframe_pivot_category_wide_month_from_long() (in module fabrictools) (in module fabrictools.transform) dataframe_unpivot_wide_month_suffix() (in module fabrictools) (in module fabrictools.transform)

delete_all_lakehouse_tables() (in module fabrictools) (in module fabrictools.io) (in module fabrictools.io.lakehouse) detect_and_cast_columns() (in module fabrictools.quality.clean), [1] drop_rows_over_empty_percent() (in module fabrictools) (in module fabrictools.transform)

E

empty_or_null() (in module fabrictools) (in module fabrictools.transform)

F

fabrictools.core module fabrictools.core.logging module fabrictools.core.paths module fabrictools.core.spark module fabrictools.dimensions module fabrictools.dimensions.date module fabrictools.dimensions.geo module fabrictools.dimensions.pipeline module fabrictools.io module fabrictools.io.discovery module fabrictools.io.lakehouse module fabrictools.io.warehouse module fabrictools.pipelines module fabrictools.pipelines.config module fabrictools.prepare module fabrictools.prepare.aggregations module fabrictools.prepare.pipeline module

fabrictools.prepare.resolve module fabrictools.prepare.schema module fabrictools.prepare.semantic module fabrictools.prepare.transform module fabrictools.quality module fabrictools.quality.clean module, [1] fabrictools.quality.pipeline module fabrictools.quality.scan module fabrictools.transform module fabrictools.transform.columns module fabrictools.transform.filter module fabrictools.transform.merge module fabrictools.transform.rows module fabrictools.transform.text module fabrictools.transform.wide_month_suffix module filter_by_value_list() (in module fabrictools) (in module fabrictools.transform) filter_pipeline_discovered_tables() (in module fabrictools.io) (in module fabrictools.io.discovery)

G

generate_dimensions() (in module fabrictools) (in module fabrictools.dimensions) (in module fabrictools.dimensions.pipeline) generate_prepared_aggregations() (in module fabrictools) (in module fabrictools.prepare) (in module fabrictools.prepare.aggregations)

get_fs_entry_name() (in module fabrictools.io.discovery) get_lakehouse_abfs_path() (in module fabrictools.core) (in module fabrictools.core.paths) get_spark() (in module fabrictools.core) (in module fabrictools.core.spark) get_warehouse_jdbc_url() (in module fabrictools.core) (in module fabrictools.core.paths)

L

list_lakehouse_tables() (in module fabrictools.io) (in module fabrictools.io.discovery) list_lakehouse_tables_for_pipeline() (in module fabrictools.io) (in module fabrictools.io.discovery)

log() (in module fabrictools.core) (in module fabrictools.core.logging)

M

make_business_ready() (in module fabrictools.prepare) merge_condition (fabrictools.pipelines.config.TableJobConfig attribute) (fabrictools.pipelines.TableJobConfig attribute) merge_dataframes() (in module fabrictools) (in module fabrictools.transform) merge_lakehouse() (in module fabrictools) (in module fabrictools.io) (in module fabrictools.io.lakehouse) mode (fabrictools.pipelines.config.TableJobConfig attribute) (fabrictools.pipelines.TableJobConfig attribute) module fabrictools.core fabrictools.core.logging fabrictools.core.paths fabrictools.core.spark fabrictools.dimensions fabrictools.dimensions.date fabrictools.dimensions.geo fabrictools.dimensions.pipeline fabrictools.io fabrictools.io.discovery fabrictools.io.lakehouse fabrictools.io.warehouse fabrictools.pipelines fabrictools.pipelines.config fabrictools.prepare fabrictools.prepare.aggregations fabrictools.prepare.pipeline fabrictools.prepare.resolve fabrictools.prepare.schema fabrictools.prepare.semantic fabrictools.prepare.transform fabrictools.quality fabrictools.quality.clean, [1] fabrictools.quality.pipeline fabrictools.quality.scan fabrictools.transform fabrictools.transform.columns fabrictools.transform.filter fabrictools.transform.merge fabrictools.transform.rows fabrictools.transform.text fabrictools.transform.wide_month_suffix

month_start_from_ca_monthly_col() (in module fabrictools) (in module fabrictools.transform)

N

norm_text() (in module fabrictools) (in module fabrictools.transform)

P

partition_by (fabrictools.pipelines.config.TableJobConfig attribute) (fabrictools.pipelines.TableJobConfig attribute) prepare_and_write_all_tables() (in module fabrictools) (in module fabrictools.prepare) (in module fabrictools.prepare.pipeline)

prepare_and_write_data() (in module fabrictools) (in module fabrictools.prepare) (in module fabrictools.prepare.pipeline) publish_semantic_model() (in module fabrictools) (in module fabrictools.prepare) (in module fabrictools.prepare.semantic)

R

read_lakehouse() (in module fabrictools) (in module fabrictools.io) (in module fabrictools.io.lakehouse) read_warehouse() (in module fabrictools) (in module fabrictools.io) (in module fabrictools.io.warehouse) remove_columns() (in module fabrictools) (in module fabrictools.transform) rename_columns_month_year_block_labels() (in module fabrictools) (in module fabrictools.transform) rename_columns_normalized() (in module fabrictools) (in module fabrictools.transform)

rename_columns_pq_serial_to_dates() (in module fabrictools) (in module fabrictools.transform) rename_columns_pq_serial_to_mois_annee() (in module fabrictools) (in module fabrictools.transform) resolve_columns() (in module fabrictools) (in module fabrictools.prepare) (in module fabrictools.prepare.resolve) resolve_dataframe_column() (in module fabrictools) (in module fabrictools.transform) resolve_lakehouse_read_candidate() (in module fabrictools.io) (in module fabrictools.io.lakehouse)

S

scan_data_errors() (in module fabrictools) (in module fabrictools.quality) (in module fabrictools.quality.scan) snapshot_source_schema() (in module fabrictools) (in module fabrictools.prepare) (in module fabrictools.prepare.schema)

source_relative_path (fabrictools.pipelines.config.TableJobConfig attribute) (fabrictools.pipelines.TableJobConfig attribute)

T

TableJobConfig (class in fabrictools.pipelines) (class in fabrictools.pipelines.config) target_relative_path (fabrictools.pipelines.config.TableJobConfig attribute) (fabrictools.pipelines.TableJobConfig attribute)

transform_to_prepared() (in module fabrictools) (in module fabrictools.prepare) (in module fabrictools.prepare.transform) transform_wide_month_suffix() (in module fabrictools) (in module fabrictools.transform)

W

wide_value_columns() (in module fabrictools) (in module fabrictools.transform) write_lakehouse() (in module fabrictools) (in module fabrictools.io) (in module fabrictools.io.lakehouse)

write_prepared_table() (in module fabrictools) (in module fabrictools.prepare) (in module fabrictools.prepare.transform) write_warehouse() (in module fabrictools) (in module fabrictools.io) (in module fabrictools.io.warehouse)