parameters{ MD_P_RawArea_IPath as string ('raw_zone/FixedWidth/2020/9/24/TBYODSTLIFPPS.csv'), MD_P_ODS_OPath as string ('ods_zone/FixedWidth/2020/9/24/TBYODSTLIFPPS'), MD_P_Container as string ('mycontainer') } source(allowSchemaDrift: true, validateSchema: false, ignoreNoFilesFound: false, rowUrlColumn: 'tmpFileName', inferDriftedColumnTypes: true, wildcardPaths:[($MD_P_RawArea_IPath)]) ~> source1 source1 alterRow(upsertIf(true())) ~> AlterRow1 AlterRow1 sink(allowSchemaDrift: true, validateSchema: false, format: 'delta', fileSystem: ($MD_P_Container), folderPath: ($MD_P_ODS_OPath), truncate: false, mergeSchema: false, vacuum: 0, deletable:false, insertable:false, updateable:false, upsertable:true, keys:[(byName('AIDNLIFDMD'))], skipDuplicateMapInputs: true, skipDuplicateMapOutputs: true) ~> sink1