{ "name": "dataflow1", "properties": { "type": "MappingDataFlow", "typeProperties": { "sources": [ { "dataset": { "referenceName": "AzureSqlTable1", "type": "DatasetReference" }, "name": "source1" } ], "sinks": [ { "dataset": { "referenceName": "AzureSqlTable1", "type": "DatasetReference" }, "name": "sink1" } ], "transformations": [ { "name": "DerivedColumn1" }, { "name": "AlterRow1" } ], "script": "source(output(\n\t\tid as integer,\n\t\tdate as timestamp,\n\t\tboolcol as integer\n\t),\n\tallowSchemaDrift: true,\n\tvalidateSchema: false,\n\tignoreNoFilesFound: false,\n\tisolationLevel: 'READ_UNCOMMITTED',\n\tformat: 'table') ~> source1\nsource1 derive(newcol = iif(equals(toString(date),\"2020-11-02 14:41:53.317\"),1,0)) ~> DerivedColumn1\nDerivedColumn1 alterRow(upsertIf(true())) ~> AlterRow1\nAlterRow1 sink(input(\n\t\tid as integer,\n\t\tdate as timestamp,\n\t\tboolcol as integer\n\t),\n\tallowSchemaDrift: true,\n\tvalidateSchema: false,\n\tdeletable:false,\n\tinsertable:false,\n\tupdateable:false,\n\tupsertable:true,\n\tkeys:['id'],\n\tformat: 'table',\n\tmapColumn(\n\t\tid,\n\t\tdate,\n\t\tboolcol = newcol\n\t),\n\tskipDuplicateMapInputs: true,\n\tskipDuplicateMapOutputs: true,\n\terrorHandlingOption: 'stopOnFirstError') ~> sink1" } } }