CREATE SINK insights.portfolio_to_account_groups_sink AS
SELECT
m.portfolio_id,
m.account_group_id,
m.type
FROM insights.portfolio_to_account_groups_mv AS m
JOIN insights.portfolio_account_group_types_mv AS pagt
ON pagt.portfolio_id = m.portfolio_id AND pagt.type = m.type
WITH (
connector='postgres',
host='psql-nonprod-uae-derived.postgres.database.azure.com',
port='6432',
user='migration_user',
password='***',
database='adib-qa-insights-db',
table='portfolio_to_account_groups_dm',
schema='insights',
type='upsert',
force_compaction='true',
primary_key='portfolio_id,account_group_id,type'
)