Hubert-Dudek
Databricks MVP

@Srinivas Gannavaram​ , in python:

spark.sql(f"""
SELECT
   CI.CORPORATE_ITEM_INTEGRATION_ID , 
   CI.CORPORATE_ITEM_CD 
WHERE
   CI.DW_CREATE_TS < '{my_timestamp_variable}' ;
""")


My blog: https://databrickster.medium.com/

View solution in original post