Sample of code to build and write on liquid clustered table

databricks_liquid_clustering.py

# Add a create stement example
# build a table
query = """
CREATE TABLE IF NOT EXISTS name_of_the_table (
column_1 DATE,
column_2 INT,
p_dateid INT NOT NULL
)
USING DELTA
CLUSTER BY (p_dateid); # you could also set CLUSTER BY AUTO , if you wanto let databrciks handle the rest
"""

# Add an insert into table , replace cmd
query = """
INSERT INTO TABLE name_of_the_table
SELECT * FROM data_to_add 
REPLACE WHERE p_dateid BETWEEN {start_dateid} AND {end_dateid}    
"""