CREATE SINK alinma_bff.marketplace_asset_taxonomy_sink AS
SELECT
asset_id,
dimension,
taxonomy_node_id,
node_name_en,
node_name_ar,
percentage
FROM alinma_bff.marketplace_asset_taxonomy_mv
WITH (
connector='postgres',
host='psql-nonprod-uae-derived.postgres.database.azure.com',
port='6432',
user='migration_user',
password='***',
database='alinma-int-advisor-portal-bff',
schema='advisor_portal_bff',
table='marketplace_asset_taxonomy',
type='upsert',
force_compaction='true',
primary_key='asset_id,dimension,taxonomy_node_id'
)