Skip to content

Instantly share code, notes, and snippets.

Show Gist options
  • Save vvgsrk/b6a6f3e14a168fee070e8feaad335694 to your computer and use it in GitHub Desktop.
Save vvgsrk/b6a6f3e14a168fee070e8feaad335694 to your computer and use it in GitHub Desktop.
Compiled version of src_product_management_product_latest_incremental.sql
WITH ranked_data AS (
SELECT
ROW_NUMBER() over (
PARTITION BY product_id
ORDER BY
__event_ts DESC
) AS row_rank,
*
FROM dev_edw_dbt_incremental_model_test.dbt_src_product_management.src_product_management_product_history
)
SELECT
"PRODUCT_ID",
"PRODUCT_NAME",
"PRICE_PER_UNIT",
"BASIC_UNIT",
"IS_STOCK_LIMITED",
"IS_ACTIVE_FOR_SALE",
"__EVENT_TS",
"__LOAD_TS",
HASH(
product_id
) AS __uuid
FROM
ranked_data
WHERE
row_rank = 1
ORDER BY __load_ts desc
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment