Index

_

__init__() (lakehouse.daft.bronze.Bronze method) (lakehouse.daft.etl.ETL method) (lakehouse.daft.gold.Gold method) (lakehouse.daft.silver.Silver method) (lakehouse.spark.bronze.Bronze method) (lakehouse.spark.etl.ETL method) (lakehouse.spark.gold.Gold method) (lakehouse.spark.silver.Silver method)

A

assert_allowed_opts() (in module lakehouse.utils.assertion) assert_class_options() (in module lakehouse.spark.utils.assertionspark) assert_col_in_dataframe() (in module lakehouse.daft.utils.assertiondaft) (in module lakehouse.spark.utils.assertionspark) assert_execute_options() (in module lakehouse.utils.assertion) assert_frame_equal() (in module lakehouse.daft.utils.daftutils) assert_load_options() (in module lakehouse.utils.assertion)

assert_optimize_options() (in module lakehouse.utils.assertion) assert_optimize_options_per_tbl() (in module lakehouse.spark.utils.assertionspark) assert_required_opts() (in module lakehouse.utils.assertion) assert_schema_equal() (in module lakehouse.daft.utils.daftutils) assert_tblproperties() (in module lakehouse.utils.assertion) assert_transform_functions() (in module lakehouse.utils.assertion) assert_transform_options() (in module lakehouse.utils.assertion) assert_write_options() (in module lakehouse.utils.assertion)

B

Bronze (class in lakehouse.daft.bronze) (class in lakehouse.spark.bronze)

C

cast_column_types() (lakehouse.daft.bronze.Bronze method) (lakehouse.daft.etl.ETL method) (lakehouse.daft.gold.Gold method) (lakehouse.daft.silver.Silver method) (lakehouse.spark.bronze.Bronze method) (lakehouse.spark.etl.ETL method) (lakehouse.spark.gold.Gold method) (lakehouse.spark.silver.Silver method) catalog (lakehouse.daft.bronze.Bronze attribute) (lakehouse.daft.etl.ETL attribute) (lakehouse.daft.gold.Gold attribute) (lakehouse.daft.silver.Silver attribute) (lakehouse.spark.bronze.Bronze attribute) (lakehouse.spark.etl.ETL attribute) (lakehouse.spark.gold.Gold attribute) (lakehouse.spark.silver.Silver attribute) checkpoint_path() (lakehouse.spark.bronze.Bronze method) (lakehouse.spark.etl.ETL method) (lakehouse.spark.gold.Gold method) (lakehouse.spark.silver.Silver method) createLogger() (in module lakehouse.utils.lhlogging) custom_filter() (lakehouse.daft.bronze.Bronze method) (lakehouse.daft.etl.ETL method) (lakehouse.daft.gold.Gold method) (lakehouse.daft.silver.Silver method) (lakehouse.spark.bronze.Bronze method) (lakehouse.spark.etl.ETL method) (lakehouse.spark.gold.Gold method) (lakehouse.spark.silver.Silver method)

custom_load() (lakehouse.daft.bronze.Bronze method) (lakehouse.daft.etl.ETL method) (lakehouse.daft.gold.Gold method) (lakehouse.daft.silver.Silver method) (lakehouse.spark.bronze.Bronze method) (lakehouse.spark.etl.ETL method) (lakehouse.spark.gold.Gold method) (lakehouse.spark.silver.Silver method) custom_transform() (lakehouse.daft.bronze.Bronze method) (lakehouse.daft.etl.ETL method) (lakehouse.daft.gold.Gold method) (lakehouse.daft.silver.Silver method) (lakehouse.spark.bronze.Bronze method) (lakehouse.spark.etl.ETL method) (lakehouse.spark.gold.Gold method) (lakehouse.spark.silver.Silver method) custom_write() (lakehouse.daft.bronze.Bronze method) (lakehouse.daft.etl.ETL method) (lakehouse.daft.gold.Gold method) (lakehouse.daft.silver.Silver method) (lakehouse.spark.bronze.Bronze method) (lakehouse.spark.etl.ETL method) (lakehouse.spark.gold.Gold method) (lakehouse.spark.silver.Silver method)

D

data (lakehouse.daft.bronze.Bronze attribute) (lakehouse.daft.etl.ETL attribute) (lakehouse.daft.gold.Gold attribute) (lakehouse.daft.silver.Silver attribute) (lakehouse.spark.bronze.Bronze attribute) (lakehouse.spark.etl.ETL attribute) (lakehouse.spark.gold.Gold attribute) (lakehouse.spark.silver.Silver attribute)

default_transform() (lakehouse.daft.bronze.Bronze method) (lakehouse.daft.etl.ETL method) (lakehouse.daft.gold.Gold method) (lakehouse.daft.silver.Silver method) (lakehouse.spark.bronze.Bronze method) (lakehouse.spark.etl.ETL method) (lakehouse.spark.gold.Gold method) (lakehouse.spark.silver.Silver method) delta_table_exists() (in module lakehouse.daft.utils.deltarsutils)

E

ETL (class in lakehouse.daft.etl) (class in lakehouse.spark.etl) execute() (lakehouse.daft.bronze.Bronze method) (lakehouse.daft.etl.ETL method) (lakehouse.daft.gold.Gold method) (lakehouse.daft.silver.Silver method) (lakehouse.spark.bronze.Bronze method) (lakehouse.spark.etl.ETL method) (lakehouse.spark.gold.Gold method) (lakehouse.spark.silver.Silver method)

G

get_databricks_connect_session() (in module lakehouse.spark.utils.settings) get_delta_merge_builder() (lakehouse.daft.bronze.Bronze method) (lakehouse.daft.etl.ETL method) (lakehouse.daft.gold.Gold method) (lakehouse.daft.silver.Silver method) (lakehouse.spark.bronze.Bronze method) (lakehouse.spark.etl.ETL method) (lakehouse.spark.gold.Gold method) (lakehouse.spark.silver.Silver method) get_replace_condition() (lakehouse.daft.bronze.Bronze method) (lakehouse.daft.etl.ETL method) (lakehouse.daft.gold.Gold method) (lakehouse.daft.silver.Silver method) (lakehouse.spark.bronze.Bronze method) (lakehouse.spark.etl.ETL method) (lakehouse.spark.gold.Gold method) (lakehouse.spark.silver.Silver method)

get_spark_opensource_session() (in module lakehouse.spark.utils.settings) Gold (class in lakehouse.daft.gold) (class in lakehouse.spark.gold)

I

io_config (lakehouse.daft.bronze.Bronze attribute) (lakehouse.daft.etl.ETL attribute) (lakehouse.daft.gold.Gold attribute) (lakehouse.daft.silver.Silver attribute)

L

lakehouse.daft.bronze module lakehouse.daft.etl module lakehouse.daft.gold module lakehouse.daft.silver module lakehouse.daft.utils.assertiondaft module lakehouse.daft.utils.daftutils module lakehouse.daft.utils.deltarsutils module lakehouse.spark.bronze module lakehouse.spark.etl module lakehouse.spark.gold module

lakehouse.spark.silver module lakehouse.spark.utils.assertionspark module lakehouse.spark.utils.settings module lakehouse.utils.assertion module lakehouse.utils.lhlogging module load() (lakehouse.daft.bronze.Bronze method) (lakehouse.daft.etl.ETL method) (lakehouse.daft.gold.Gold method) (lakehouse.daft.silver.Silver method) (lakehouse.spark.bronze.Bronze method) (lakehouse.spark.etl.ETL method) (lakehouse.spark.gold.Gold method) (lakehouse.spark.silver.Silver method) log() (in module lakehouse.utils.lhlogging)

M

module lakehouse.daft.bronze lakehouse.daft.etl lakehouse.daft.gold lakehouse.daft.silver lakehouse.daft.utils.assertiondaft lakehouse.daft.utils.daftutils lakehouse.daft.utils.deltarsutils lakehouse.spark.bronze lakehouse.spark.etl lakehouse.spark.gold lakehouse.spark.silver lakehouse.spark.utils.assertionspark lakehouse.spark.utils.settings lakehouse.utils.assertion lakehouse.utils.lhlogging

O

optimize() (lakehouse.spark.bronze.Bronze method) (lakehouse.spark.etl.ETL method) (lakehouse.spark.gold.Gold method) (lakehouse.spark.silver.Silver method) options (lakehouse.daft.bronze.Bronze attribute) (lakehouse.daft.etl.ETL attribute) (lakehouse.daft.gold.Gold attribute) (lakehouse.daft.silver.Silver attribute) (lakehouse.spark.bronze.Bronze attribute) (lakehouse.spark.etl.ETL attribute) (lakehouse.spark.gold.Gold attribute) (lakehouse.spark.silver.Silver attribute)

R

rename_columns() (lakehouse.daft.bronze.Bronze method) (lakehouse.daft.etl.ETL method) (lakehouse.daft.gold.Gold method) (lakehouse.daft.silver.Silver method) (lakehouse.spark.bronze.Bronze method) (lakehouse.spark.etl.ETL method) (lakehouse.spark.gold.Gold method) (lakehouse.spark.silver.Silver method)

S

select_columns() (lakehouse.daft.bronze.Bronze method) (lakehouse.daft.etl.ETL method) (lakehouse.daft.gold.Gold method) (lakehouse.daft.silver.Silver method) (lakehouse.spark.bronze.Bronze method) (lakehouse.spark.etl.ETL method) (lakehouse.spark.gold.Gold method) (lakehouse.spark.silver.Silver method) Silver (class in lakehouse.daft.silver) (class in lakehouse.spark.silver) source_path() (lakehouse.daft.bronze.Bronze method) (lakehouse.daft.etl.ETL method) (lakehouse.daft.gold.Gold method) (lakehouse.daft.silver.Silver method)

source_schema (lakehouse.daft.etl.ETL attribute) (lakehouse.daft.gold.Gold attribute) (lakehouse.daft.silver.Silver attribute) (lakehouse.spark.etl.ETL attribute) (lakehouse.spark.gold.Gold attribute) (lakehouse.spark.silver.Silver attribute) spark (lakehouse.spark.bronze.Bronze attribute) (lakehouse.spark.etl.ETL attribute) (lakehouse.spark.gold.Gold attribute) (lakehouse.spark.silver.Silver attribute)

T

target_path() (lakehouse.daft.bronze.Bronze method) (lakehouse.daft.etl.ETL method) (lakehouse.daft.gold.Gold method) (lakehouse.daft.silver.Silver method) (lakehouse.spark.bronze.Bronze method) (lakehouse.spark.etl.ETL method) (lakehouse.spark.gold.Gold method) (lakehouse.spark.silver.Silver method) target_schema (lakehouse.daft.bronze.Bronze attribute) (lakehouse.daft.etl.ETL attribute) (lakehouse.daft.gold.Gold attribute) (lakehouse.daft.silver.Silver attribute) (lakehouse.spark.bronze.Bronze attribute) (lakehouse.spark.etl.ETL attribute) (lakehouse.spark.gold.Gold attribute) (lakehouse.spark.silver.Silver attribute)

tblproperties() (lakehouse.spark.bronze.Bronze method) (lakehouse.spark.etl.ETL method) (lakehouse.spark.gold.Gold method) (lakehouse.spark.silver.Silver method) transform() (lakehouse.daft.bronze.Bronze method) (lakehouse.daft.etl.ETL method) (lakehouse.daft.gold.Gold method) (lakehouse.daft.silver.Silver method) (lakehouse.spark.bronze.Bronze method) (lakehouse.spark.etl.ETL method) (lakehouse.spark.gold.Gold method) (lakehouse.spark.silver.Silver method)

W

write() (lakehouse.daft.bronze.Bronze method) (lakehouse.daft.etl.ETL method) (lakehouse.daft.gold.Gold method) (lakehouse.daft.silver.Silver method) (lakehouse.spark.bronze.Bronze method) (lakehouse.spark.etl.ETL method) (lakehouse.spark.gold.Gold method) (lakehouse.spark.silver.Silver method)