Index

A

alter_delta_table_properties() (in module lakehouse.databricks.common)

B

build_la_signature() (in module lakehouse.databricks.log_analytics_logging)

C

cdm_view_sql_conversion() (in module lakehouse.databricks.udfs) create_aggregate_dataframe() (in module lakehouse.databricks.common) create_anti_merge_predicate() (in module lakehouse.databricks.common) create_catalog_not_exists() (in module lakehouse.databricks.common) create_database_not_exists() (in module lakehouse.databricks.common) create_delta_table() (in module lakehouse.databricks.common)

create_folder_structure() (in module lakehouse.databricks.common) create_merge_dict() (in module lakehouse.databricks.common) create_merge_predicate() (in module lakehouse.databricks.common) create_mount() (in module lakehouse.databricks.common) create_path_not_exists() (in module lakehouse.databricks.common) create_type_two_condition() (in module lakehouse.databricks.common)

D

delete_files_in_folder() (in module lakehouse.databricks.common) delta_merge() (in module lakehouse.databricks.common)

do_vacuum_and_optimize() (in module lakehouse.databricks.common) drop_all_tables() (in module lakehouse.databricks.common)

F

function_name() (in module lakehouse.databricks.common_helpers)

G

generate_delta_load_rowsOutput() (in module lakehouse.databricks.common) generate_delta_load_stats() (in module lakehouse.databricks.common) generate_expectation_meta_behaviour() (in module lakehouse.databricks.common) generate_expectation_results() (in module lakehouse.databricks.common) generate_sql_expectation_table_validation_result_queries() (in module lakehouse.databricks.common) get_all_tables() (in module lakehouse.databricks.common) get_cdm_entities_to_integrate() (in module lakehouse.databricks.cdm) get_cdm_tables_to_process() (in module lakehouse.databricks.cdm)

get_cdm_trickle_tables_to_process() (in module lakehouse.databricks.cdm) get_db_utils() (in module lakehouse.databricks.common_helpers) get_delta_floor_pred_for_sql() (in module lakehouse.databricks.common) get_dependent_entities_to_integrate() (in module lakehouse.databricks.cdm) get_ga_4_data() (in module lakehouse.databricks.ga) get_parent_entities_to_integrate() (in module lakehouse.databricks.cdm) get_partition_key_vals_for_pruning() (in module lakehouse.databricks.common) get_workspace_login_creds() (in module lakehouse.databricks.log_analytics_logging)

J

jinga_reference() (in module lakehouse.databricks.common)

M

main() (in module lakehouse.databricks.functions.helpers)

O

optimize_table() (in module lakehouse.databricks.common)

P

post_la_data() (in module lakehouse.databricks.log_analytics_logging) process_cdm_entity() (in module lakehouse.databricks.cdm)

process_cdm_table_bronze() (in module lakehouse.databricks.cdm) process_silver_stream_definition() (in module lakehouse.databricks.stream) process_transform_definition() (in module lakehouse.databricks.transform_data)

R

read_data_lake_query() (in module lakehouse.databricks.common) read_datalake_file() (in module lakehouse.databricks.common)

repartition_delta_table() (in module lakehouse.databricks.common) rollback_delta_table_by_version() (in module lakehouse.databricks.common)

S

sql_data_type_replace() (in module lakehouse.databricks.common)

stream_cdm_table_silver() (in module lakehouse.databricks.cdm)

T

truncate_all_tables() (in module lakehouse.databricks.common)

V

vacumm_and_optimize_all_tables() (in module lakehouse.databricks.common)

vacuum_table() (in module lakehouse.databricks.common)

W

write_file_to_datalake() (in module lakehouse.databricks.common)