Skip to content

Commit dc09e50

Browse files
authored
[SNOW-151] Initialize dynamic table: accessrequirement_latest (#84)
1 parent d06228f commit dc09e50

File tree

1 file changed

+26
-0
lines changed

1 file changed

+26
-0
lines changed
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
use schema {{database_name}}.synapse; --noqa: JJ01,PRS,TMP,CP01
2+
3+
CREATE DYNAMIC TABLE IF NOT EXISTS ACCESSREQUIREMENT_LATEST
4+
TARGET_LAG = '1 day'
5+
WAREHOUSE = compute_xsmall
6+
AS
7+
WITH latest_unique_rows AS (
8+
SELECT
9+
*
10+
FROM
11+
{{database_name}}.synapse_raw.accessrequirementsnapshots --noqa: TMP
12+
WHERE
13+
SNAPSHOT_TIMESTAMP >= CURRENT_TIMESTAMP - INTERVAL '14 DAYS'
14+
QUALIFY ROW_NUMBER() OVER (
15+
PARTITION BY id
16+
ORDER BY change_timestamp DESC, snapshot_timestamp DESC
17+
) = 1
18+
)
19+
SELECT
20+
*
21+
FROM
22+
latest_unique_rows
23+
WHERE
24+
CHANGE_TYPE != 'DELETE'
25+
ORDER BY
26+
latest_unique_rows.id ASC;

0 commit comments

Comments
 (0)