Skip to content

Commit d260591

Browse files
committed
Removed redundant duplicate detection
Removed redundant duplicate detection by removing rownum window function
1 parent 7bf0b27 commit d260591

File tree

1 file changed

+3
-15
lines changed

1 file changed

+3
-15
lines changed

templates/Copy Dataverse data into Azure SQL/DataverseToSQL_Orchestrator.json

Lines changed: 3 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -343,7 +343,7 @@
343343
},
344344
"annotations": [
345345
],
346-
"lastPublishTime": "2022-10-25T21:59:00Z"
346+
"lastPublishTime": "2023-01-20T06:39:09Z"
347347
},
348348
"dependsOn": [
349349
"[concat(variables('factoryId'), '/datasets/DataverseToSQLDestination')]",
@@ -1088,7 +1088,7 @@
10881088
},
10891089
"annotations": [
10901090
],
1091-
"lastPublishTime": "2022-10-24T21:31:28Z"
1091+
"lastPublishTime": "2022-10-28T09:11:04Z"
10921092
},
10931093
"dependsOn": [
10941094
"[concat(variables('factoryId'), '/datasets/OptionsetMetadataSourceDataset')]",
@@ -1481,12 +1481,6 @@
14811481
},
14821482
{
14831483
"name": "SelectDeleteLogColumns"
1484-
},
1485-
{
1486-
"name": "RankRowNum"
1487-
},
1488-
{
1489-
"name": "DeDupRowNum"
14901484
}
14911485
],
14921486
"scriptLines": [
@@ -1529,7 +1523,7 @@
15291523
" desc(SinkModifiedOn, false),",
15301524
" {_RowVersion} = denseRank()) ~> Rank",
15311525
"Rank filter(toLong(byName(\"_RowVersion\"))==1) ~> Dedup",
1532-
"DeDupRowNum, getMaxVersion join(versionnumber > maxversion,",
1526+
"Dedup, getMaxVersion join(versionnumber > maxversion,",
15331527
" joinType:'left',",
15341528
" matchType:'exact',",
15351529
" ignoreSpaces: false,",
@@ -1544,12 +1538,6 @@
15441538
" ),",
15451539
" skipDuplicateMapInputs: false,",
15461540
" skipDuplicateMapOutputs: true) ~> SelectDeleteLogColumns",
1547-
"Dedup window(over(Id),",
1548-
" desc(Id, false),",
1549-
" desc(versionnumber, false),",
1550-
" desc(SinkModifiedOn, false),",
1551-
" {_RowNum} = rowNumber()) ~> RankRowNum",
1552-
"RankRowNum filter(toLong(byName(\"_RowNum\"))==1) ~> DeDupRowNum",
15531541
"AlterRow sink(allowSchemaDrift: true,",
15541542
" validateSchema: false,",
15551543
" format: 'table',",

0 commit comments

Comments
 (0)