File tree Expand file tree Collapse file tree 2 files changed +14
-2
lines changed Expand file tree Collapse file tree 2 files changed +14
-2
lines changed Original file line number Diff line number Diff line change 41934193 {
41944194 "name" : " FilterEmptyHappinessScore" ,
41954195 "description" : " Filter Empty Happiness Score Rows"
4196+ },
4197+ {
4198+ "name" : " HarmonizeColumn" ,
4199+ "description" : " Harmonize columns: Connection, DeviceVendor"
41964200 }
41974201 ],
41984202 "scriptLines" : [
42524256 " skipDuplicateMapInputs: true," ,
42534257 " skipDuplicateMapOutputs: true) ~> RenameColumns" ,
42544258 " RenameColumns filter(!isNull(HappinessScore)) ~> FilterEmptyHappinessScore" ,
4255- " FilterEmptyHappinessScore sink(allowSchemaDrift: true," ,
4259+ " FilterEmptyHappinessScore derive(Connection = lower(Connection)," ,
4260+ " DeviceVendor = lower(DeviceVendor)) ~> HarmonizeColumn" ,
4261+ " HarmonizeColumn sink(allowSchemaDrift: true," ,
42564262 " validateSchema: false," ,
42574263 " format: 'delta'," ,
42584264 " fileSystem: ($sinkFileSystem)," ,
Original file line number Diff line number Diff line change 10431043 {
10441044 "name" : " FilterEmptyHappinessScore" ,
10451045 "description" : " Filter Empty Happiness Score Rows"
1046+ },
1047+ {
1048+ "name" : " HarmonizeColumn" ,
1049+ "description" : " Harmonize columns: Connection, DeviceVendor"
10461050 }
10471051 ],
10481052 "scriptLines" : [
11021106 " skipDuplicateMapInputs: true," ,
11031107 " skipDuplicateMapOutputs: true) ~> RenameColumns" ,
11041108 " RenameColumns filter(!isNull(HappinessScore)) ~> FilterEmptyHappinessScore" ,
1105- " FilterEmptyHappinessScore sink(allowSchemaDrift: true," ,
1109+ " FilterEmptyHappinessScore derive(Connection = lower(Connection)," ,
1110+ " DeviceVendor = lower(DeviceVendor)) ~> HarmonizeColumn" ,
1111+ " HarmonizeColumn sink(allowSchemaDrift: true," ,
11061112 " validateSchema: false," ,
11071113 " format: 'delta'," ,
11081114 " fileSystem: ($sinkFileSystem)," ,
You can’t perform that action at this time.
0 commit comments